1

我必须从 Azure 加载一些对象。我计划将它们加载 5 到 5 以减少时间（一种延迟加载）：

ProductManager.LoadProduct 调用我的 ProductAccess.LoadProduct 最后一个方法从 azure 加载产品，然后引发事件以便经理可以获取产品。然后，如果它收到产品，它会再次调用 ProductAccess.LoadProduct。ETC ....

不能使用 await/async，因为它是跨平台代码（monodroid/monotouch 稳定版仍然没有 await/async）。

第一次加载是正确的，然后第二次调用有效，但似乎我的任务没有执行（开始不执行我的第二个任务......）。我检查了线程号，第二次，Task.Factory.StartNew(() => 在主线程上执行。我尝试通过指定长时间运行来修复它，但仍然不起作用。

这是我的代码：

经理方：

public void LoadProduct() 
{
    ProductAccess.LoadProductsAsync()
}

public void receiveProductsAsync(Object pa, EventArgs e)
{
    if (((ProductEventArgs)e).GetAttribute.Equals("LoadProductsAsync"))
    {
        IoC.Resolve<IProductAccess>().RequestEnded -= receiveProductsAsync;

        if ( ((ProductEventArgs)e).LP).Count() != 0)                       
           LoadProductsAsync();

        Products = Products.Concat(((ProductEventArgs)e).LP).ToList();
        if (((ProductEventArgs)e).E != null)
        {
            if (RequestEnded != null)
                RequestEnded(this, new OperationEventArgs() { Result = false, E = ((ProductEventArgs)e).E, GetAttribute = "LoadProductsAsync" });
        }
        else
        {
            if (RequestEnded != null)
            {
                RequestEnded(this, new OperationEventArgs() { Result = true, GetAttribute = "LoadProductsAsync" });
            }
        }
    }
}

接入端：

public void LoadProductsAsync()
{
    Task<ProductEventArgs>.Factory.StartNew(() =>
    {
        var longRunningTask = new Task<ProductEventArgs>(() =>
        {
            try
            {
                var _items = this.table.Select(x => new Product(.....)).Skip(nbrProductLoaded).Take(nbrProductToLoadAtEachTime).ToListAsync().Result;
                this.nbrProductLoaded += _items.Count();
                Task.Factory.StartNew(() => synchronizeFavorite(_items));
                return new ProductEventArgs() { LP = _items, GetAttribute = "LoadProductsAsync" };
            }
            catch (Exception e)
            {
                return new ProductEventArgs() { E = e, GetAttribute = "LoadProductsAsync" };
            }
        }, TaskCreationOptions.LongRunning);

        longRunningTask.Start();

        if (longRunningTask.Wait(timeout)) 
            return longRunningTask.Result;

        return new ProductEventArgs() { E = new Exception("timed out"), GetAttribute = "LoadProductsAsync" };

    }, TaskCreationOptions.LongRunning).ContinueWith((x) => {
        handleResult(x.Result);
    }, TaskScheduler.FromCurrentSynchronizationContext());
}
4

1 回答 1

1

Task.Factory.StartNew默认情况下将使用当前的TaskScheduler.

第一次，您没有在任务中运行，因此当前TaskScheduler是默认值TaskScheduler（它将在线程池上运行）。

当您使用 调度handleResult回原始上下文TaskScheduler.FromCurrentSynchronizationContext时，它将handleResult在主线程上的任务中运行。因此，在这种情况下，当前TaskScheduler是 UI TaskScheduler，而不是默认值TaskScheduler。

要解决此问题，请显式传递TaskScheduler.Default给StartNew要在线程池线程上运行的任何线程（并删除LongRunning）。

于 2013-05-31T11:36:08.193 回答