0

我以下面的方式创建了几个任务。但它似乎WaitAll不起作用。它正在发送响应而无需等待。这里有什么问题吗?

private void GetItemsPrice(IEnumerable<Item> items, int customerNumber)
    {
        try
        {
            var tasks = new List<Task>();

            for (var i = 0; i < items.Count(); i += 50)
            {
                var newTask = DoGetItemsPrice(items.Skip(i).Take(50), customerNumber);    
                tasks.Add(newTask);
            }

            Task.WaitAll(tasks.ToArray());
        }
        catch (Exception ex)
        {
            ErrorLog.WriteLog(GetType().Name, "GetItemsPrice", string.Format("customerNumber={0}", customerNumber), ex.Message);
        }
    }

private static Task DoGetItemsPrice(IEnumerable<Item> items, int customerNumber)
    {
        return Task.Factory.StartNew(() =>
        {
            var sxApiObj = new SxApiService();
            var request = new OEPricingMultipleRequest();

            request.customerNumber = customerNumber;
            request.arrayProduct =
                items.Select(
                    itemCode =>
                    new OEPricingMultipleinputProduct
                    {
                        productCode = itemCode.ItmNum,
                        quantity = itemCode.Quantity,
                        warehouse = ConfigurationVariables.DefaultWareHouse
                    }).ToArray();
            var response = sxApiObj.OEPricingMultiple(ConfigurationVariables.SfAppServer,
                                                  ConfigurationVariables.SfUserId,
                                                  ConfigurationVariables.SfPassword,
                                                  request);

            if (response.arrayPrice != null)
            {
                foreach (var priceData in response.arrayPrice)
                {
                    var productCode = priceData.productCode;
                    var item = items.FirstOrDefault(itm => itm.ItmNum == productCode);

                    if (item == null) continue;
                    item.ItmListPrice1 = priceData.price.ToString("c", ConfigurationVariables.UsCulture);
                    item.ItmListPrice2 = priceData.discountAmount.ToString("c", ConfigurationVariables.UsCulture);
                    item.ItmListPrice3 = priceData.extendedAmount.ToString("c", ConfigurationVariables.UsCulture);

                    item.Quantity = priceData.netAvailable;
                }
            }
        });
    }
4

1 回答 1

0

我的问题没有错。WaitAll工作正常,代码也正确。

于 2013-03-14T04:24:30.587 回答