主页 / user-223020

Daniel Protopopov's questions

Martin Hope
Daniel Protopopov
Asked: 2024-12-26 16:11:10 +0000 UTC
  • 5

我有一个类似的机制pub/sub，通过 实现Queue<T>，我delegate将消息放入队列中，然后在一般循环中开始处理它们，Dataflow.ActionBlock通过以下方式限制最大块数MaxDegreeOfParallelism：

Console.WriteLine($"Processing {ClosedOrders.Count} closed orders ...");
var closedOrdersBlock = new ActionBlock<OrderMessage>(OnPositionClosed,
            new ExecutionDataflowBlockOptions { MaxDegreeOfParallelism = 8 });
while (ClosedOrders.Count > 0)
{
   ClosedOrders.TryDequeue(out var closedOrder);
   if (closedOrder != null)
      closedOrdersBlock.Post(closedOrder);
 }

 closedOrdersBlock.Complete();
 closedOrdersBlock.Completion.Wait();

这是委托处理：

protected virtual void OnPositionClose(OrderMessage message)
    {
        try
        {
            foreach (var orderToClose in ClosedOrders.ToList())
            {
                if (message.Order == null || orderToClose.Order == null ||
                    orderToClose.Order.Ticket != message.Order.Ticket) continue;
                Console.WriteLine("Duplicate order for closing received for ticket " + orderToClose.Order.Ticket +
                                  ", skipping");
                return;
            }

            ClosedOrders.Enqueue(message);
        }
        catch (Exception ex)
        {
            Console.WriteLine($"Failed to enqueue order with ticket {message.Order?.Ticket} for closing: {ex.Message}");
            Console.WriteLine($"Stack trace: {ex.StackTrace}");
        }
    }

发生错误

“未能将关闭顺序排入队列：集合已修改；枚举操作可能无法执行。”

，据我了解，发生这种情况是因为我在处理队列时向队列添加了新条目，尽管异常表明这种情况发生在 foreach 循环中的委托本身中。这意味着什么？我没有对其进行任何更改，我只是浏览列表并检查数据，但我不会以任何方式更改它。

或者这是因为在处理过程中，新记录被放入队列中？

c#
Martin Hope
Daniel Protopopov
Asked: 2023-05-19 05:19:13 +0000 UTC
  • 5

我正在尝试在项目中实现后处理，并在序列化为 JSON 之前处理结构（不同的结构用于 API 响应）以便将货币转换为给定的货币。

可用的：

包含价格和货币的结构

 type Price struct {
        Amount decimal.Decimal `json:"Amount"`
        Currency string `json:"Currency`"
    }

答案结构#1：

type ExampleRS struct {
    Total price.Price `json:"Total"`
}

答案 #2 的附加结构

type ResponseEntry struct {
   ExampleIntValue int `json:"ExampleValue"`
   ExampleStringArrayValues []string `json:"ExampleStringArrayValues"`
   Price price.Price `json:"Price"`
}

答案结构#2

  type ExampleListRS struct {
        Data []ResponseEntry `json:"Response"`
        PerPage uint `json:"Count"`
        Pages uint `json:"Pages"`
    }

问题是如何实现将 interface{} 作为输入或 reflect.ValueOf 而不是特定类型（ExampleListRS 或 ExampleRS）的方法，这将递归地遍历结构，检查 price.Price，并乘以 decimal.Decimal在里面，比方说，5？

我试图通过一个例子来实现它，但我不明白如何比较（和什么）与 price.Price 类型。

golang
Martin Hope
Daniel Protopopov
Asked: 2020-11-12 20:14:59 +0000 UTC
  • 4

告诉我，PHP 和其中一个缓存系统中是否有一种机制，您可以使用它为存储它们的块分配最大条目数和不同类型的行为？让我举个例子 - 在工作完成一定时间（例如，最多 10 分钟）后需要保存数据，但您需要添加对“地点”数量的控制（例如，最多 1000 ) 分配给此数据以及分配多长时间。你还需要考虑到有不同类型的数据（最终数量约为25-20），并为每种类型做一个循环缓存。在 memcache 中，这可以通过将数据头存储在单独的块中来完成，但是是否有具有此类功能的插件或扩展？

同样，数据类型的大小是固定的，所以如果有解决方案可以重用分配的内存以减少内存碎片，那么这是另一个很大的优势。

php
Martin Hope
Daniel Protopopov
Asked: 2020-03-14 17:36:35 +0000 UTC
  • 1

我在前端有一些类，比如 HotelsController 和其他类，它们可以通过搜索模块作为 search/hotels/ 访问。

function getUrlRules()
{
return array(
        $this->id.'/<controller:\w+>/<action:(SupportBlock)>/<countryId:\d+>' => $this->id.'/<controller>/<action>',
        $this->id.'/<controller:\w+>/<action:(SupportBlock)>/<countryId:\d+>/<cityId:\d+>' => $this->id.'/<controller>/<action>'
    );

}

问题是，如果我将类名从 HotelsController 更改为 FrontendHotelsController，我如何确保 PATH (search/hotels/) 保持不变而不是更改为 search/frontendhotels/ ？我试图将前端添加到路由，但它在那里不起作用，它给出了一个错误“无法处理请求“搜索/酒店””

php