可暂停和可恢复的异步任务队列

Question

我已经根据我在此处找到的内容实现了一个工作队列 > Task queue for wp8? ...但在实现附加功能时遇到了麻烦。

我取出了 Func<Task> 并用 ICommands 替换它们（持有它们自己的 CancellationTokens），并打算添加 Pause()、Resume()、Save() 和 Restore() 方法。就是这样OnFormClose() 我可以暂停队列处理并提示用户决定他是要“等待队列完成”（即恢复）还是“立即退出”（即保存并退出）。

public class WqController
{
    private readonly Queue<ICommand> _queue = new Queue<ICommand>();
    private Task _queueProcessor;
    private ICommand _curCommand;

    public void Enqueue(ICommand command)
    {
        _queue.Enqueue(command);

        if (_queueProcessor == null) _queueProcessor = ProcessQueue();
    }

    private async Task ProcessQueue()
    {
        try
        {
            while (_queue.Count != 0)
            {
                _curCommand = _queue.Peek();

                try
                {
                    await Task.Run(() => _curCommand.Execute());
                }
                catch (OperationCanceledException)
                {
                    Console.WriteLine("QUEUE PAUSED");
                    return;
                }
                catch (Exception)
                {
                    Console.WriteLine("FAILED TO EXECUTE COMMAND");
                }
                _queue.Dequeue();
            }
        }
        finally
        {
            _queueProcessor = null;
            _curCommand = null;
        }
    }

    public async Task Cancel()
    {
        _curCommand.Cts.Cancel(true);
        await _queueProcessor;
    }

    public void Resume()
    {
        _queueProcessor = ProcessQueue();
    }
}

Save() 和 Restore() 工作正常，所以我没有将它们包括在这里。 Cancel() 间歇性/不可靠地工作，Restore() 似乎根本不起作用（令我困惑，因为我基本上尝试与 Enqueue() 方法中的工作相同的重启）。

Answer 1

我得到了这个工作，并认为我应该在这里概述我的解决方案。

事实证明，我对取消令牌的使用有点随意，这导致此类无法按预期运行。例如，以下问题是相关的：

1. 如果在命令中通过最后一次取消检查后调用 Cancel，则将加载一个新命令（连同它自己的新取消令牌），因此取消调用将丢失/忽略。在_queue.Dequeue(); 之后，if (_curCommand.Cts.Token.IsCancellationRequested) return; 解决了这个问题。

2. 调用取消后，如果稍后要恢复该命令，则需要一个新的取消令牌（否则取消 = true 的现有取消令牌仍将处于活动状态）。 _curCommand.InvalidateCancellationToken(); 行通过将令牌设置为 null 来实现这一点，然后我的命令在下次调用时刷新令牌。

我使用的完整代码：

public class WqController
{
    private readonly Queue<ICommand> _queue = new Queue<ICommand>();
    private Task _queueProcessor;
    private ICommand _curCommand;

    public void Enqueue(ICommand command)
    {
        _queue.Enqueue(command);

        if (_queueProcessor == null) _queueProcessor = ProcessQueue();
    }

    private async Task ProcessQueue()
    {
        try
        {
            while (_queue.Count != 0)
            {
                _curCommand = _queue.Peek();

                try
                {
                    await Task.Run(() => _curCommand.Execute());
                }
                catch (OperationCanceledException)
                {
                    _curCommand.InvalidateCancellationToken();
                    Console.WriteLine("QUEUE PAUSED");
                    return;
                }
                catch (Exception)
                {
                    Console.WriteLine("FAILED TO EXECUTE COMMAND");
                }
                _queue.Dequeue();
                if (_curCommand.Cts.Token.IsCancellationRequested) return;
            }
        }
        finally
        {
            _queueProcessor = null;
            _curCommand = null;
        }
    }

    public async Task Cancel()
    {
        _curCommand.Cts.Cancel(true);
        await _queueProcessor;
    }

    public void Resume()
    {
        _queueProcessor = ProcessQueue();
    }
}

这一切现在似乎运行得非常顺利，并且是对我之前使用的后台工作队列实现的重大改进。