仅运行当前任务和最近排队的任务

Question

我有一些方法。我们称它们为“TurnOn”和“TurnOff”。每个都返回一个未启动的任务（如 System.Threading.Tasks.Task 中）。一旦开始，该任务大约需要一秒钟才能完成。我有一些代码可以使用 Task.ContinueWith 方法（显示为here）对这些进行排队。问题是我真的只想运行当前正在运行的任务（如果有的话）加上最近请求的任务。目前，如果我的用户在一秒钟内切换开/关开关十次，我的代码需要 20 秒才能赶上。这只是我关心的最后一个请求。我怎样才能做到这一点？我看不到 ContinueWith 方法中的方法来知道它之后是否还有另一个 ContinueWith 方法。我一直在查看示例 here，但不太了解如何应用它。

更新：现在可以在此处的库中找到它：https://github.com/BrannonKing/Kts.ActorsLite。它被命名为“最近...”

Answer 1

只需创建一个类来跟踪当前正在执行的任务、下一个要运行的动作，并且只要前一个动作完成就运行“下一个”动作。这里的关键是，如果下一个操作在您将新操作排入队列时具有值，您可以简单地替换 nextTask 而不是添加另一个延续。

public class TaskQueue
{
    private Task currentlyExecuting = Task.FromResult(false);
    public Task continuation = null;
    private CancellationTokenSource cts = new CancellationTokenSource();
    private Action nextTask = null;
    private object key = new object();
    public Task Queue(Action action)
    {
        lock (key)
        {
            if (nextTask == null)
            {
                nextTask = action;
                ScheduleContinuation();
                return continuation;
            }
            else
            {
                cts.Cancel();
                nextTask = action;
                ScheduleContinuation();
                return continuation;
            }
        }
    }

    private void ScheduleContinuation()
    {
        cts = new CancellationTokenSource();
        var token = cts.Token;
        continuation = currentlyExecuting.ContinueWith(t =>
        {
            lock (key)
            {
                currentlyExecuting = Task.Run(nextTask);
                token.ThrowIfCancellationRequested();
                nextTask = null;
            }
        }, cts.Token);
    }
}

虽然您可以在此处接受未启动的任务，并且这样做是非常简单的重写，但我认为在这里接受委托并创建然后启动任务是更好的做法可以开始了。