c# - 无限循环异步

Question

我有一个需要实时更新的数据集列表。我想一次处理 100 多个中的 10 个，然后一旦完成，就抓取下一个最旧的行。基本上让这个循环持续无限长的时间。我对线程世界很陌生，并且一直在 AsyncTask 上闲逛。有没有人可以指出我的例子？我用谷歌搜索了很多，但找不到我要找的东西。

Answer 1

如果您知道我的意思，至少在 .Net 4.5 中，异步编程变得非常有趣。

这是一组简单的示例：

public async void DoAsync()
{
      await Task.Run( () =>
      { 
         // Do task! 
      } );
}

public async Task<string> GetStringAsync()
{
       string s = "";
       await Task.Run( () =>
       {
            for(int I = 0; I < 9999999; I++)
            {
                   s += I.ToString();
            }
       }
       return s;
}

有用的资源

http://msdn.microsoft.com/en-us/library/vstudio/hh191443.aspx

Answer 2

AsyncTask更适合一次性操作。对于正在进行的任务，您可以考虑使用工作线程。

免责声明：我不认为这是最好的方法，但它应该给你一些想法和东西来阅读。

    public class ThreadingSample : IDisposable
{
    private Queue<SomeObject> _processingQueue = new Queue<SomeObject>();
    private Thread _worker;
    private volatile bool _workerTerminateSignal = false;
    private EventWaitHandle _waitHandle = new EventWaitHandle(false, EventResetMode.AutoReset);

    public bool HasQueuedItem
    {
        get
        {
            lock(_processingQueue)
            {
                return _processingQueue.Any();
            }
        }
    }

    public SomeObject NextQueuedItem
    {
        get
        {
            if ( !HasQueuedItem )
                return null;

            lock(_processingQueue)
            {
                return _processingQueue.Dequeue();
            }
        }
    }

    public void AddItem(SomeObject item)
    {
        lock(_processingQueue)
        {
            _processingQueue.Enqueue(item);
        }
        _waitHandle.Set();
    }
    public ThreadingSample()
    {
        _worker = new Thread(ProcessQueue);
        _worker.Start();
    }

    private void ProcessQueue()
    {
        while(!_workerTerminateSignal)
        {
            if ( !HasQueuedItem )
            {
                Console.WriteLine("No items, waiting.");
                _waitHandle.WaitOne();
                Console.WriteLine("Waking up...");
            }
            var item = NextQueuedItem;
            if (item != null)   // Item can be missing if woken up when the worker is being cleaned up and closed.
                Console.WriteLine(string.Format("Worker processing item: {0}", item.Data));
        }
    }

    public void Dispose()
    {
        if (_worker != null)
        {
            _workerTerminateSignal = true;
            _waitHandle.Set();
            if ( !_worker.Join( TimeSpan.FromMinutes( 1 ) ) )
            {
                Console.WriteLine("Worker busy, aborting the thread.");
                _worker.Abort();
            }
            _worker = null;
        }
    }

    public class SomeObject
    {
        public string Data
        {
            get;
            set;
        }
    }
}

测试它我使用单元测试来启动它。您可以将单元测试扩展为适当的测试，以确保按预期执行操作。在我的情况下，它们是一个很好的初始断言，可以消除行为。

        [Test]
    public void TestThreading()
    {
        using ( var sample = new ThreadingSample() )
        {
            sample.AddItem(new ThreadingSample.SomeObject {Data = "First Item"});
            sample.AddItem(new ThreadingSample.SomeObject {Data = "Second Item"});
            Thread.Sleep(50);
            sample.AddItem(new ThreadingSample.SomeObject {Data = "Third Item"});
        }

    }

测试的相关输出：

------ 测试开始： 程序集：NHMapping.dll ------

Worker 处理项：First Item
Worker 处理项：Second Item
无项，等待。
醒来...
没有物品，等待。
醒来...
工人处理项目：第三个项目
没有项目，等待。
醒来...

1 次通过，0 次失败，0 次跳过，耗时 0.12 秒（临时）。

在这里，您可以看到工作人员进入睡眠状态，然后醒来处理队列中的项目。从技术上讲，您可以使用一个列表，然后从列表中获取 10 个项目，然后再将其从锁中释放，并在再次检查列表之前处理这 10 个项目。

当类被释放时，它会释放循环，然后等待工作线程在中止之前终止。在这里，您可能想要检查任何未完成的项目并记录它们将不会被处理，或者将它们保存到文件以供以后处理。

编辑：我发现了双重事件的问题......更好的实现是ManualReset在EventWaitHandle

private EventWaitHandle _waitHandle = new EventWaitHandle(false, EventResetMode.ManualReset);

然后在处理处理项目的情况时，重新发送句柄：

                var item = NextQueuedItem;
            if (item != null)   // Item can be missing if woken up when the worker is being cleaned up and closed.
            {
                Console.WriteLine(string.Format("Worker processing item: {0}", item.Data));
                _waitHandle.Reset();
            }

这会产生更好的测试结果：

------ 测试开始： 程序集：NHMapping.dll ------

Worker 处理项：First Item
Worker 处理项：Second Item
无项，等待。
醒来...
工人处理项目：第三个项目
没有项目，等待。
醒来...

1 次通过，0 次失败，0 次跳过，耗时 0.13 秒（临时）。