使用任务执行延迟的“计时器式”操作

Question

我的应用程序中有一个事件，它改变了对象的状态并引用该状态以在 10 秒后重置。但如果在这 10 秒内再次触发该事件，则该事件不会更改状态，而只是将计时器重置为零。

为了简明易懂，这是我的代码的作用

1. 我有一个安排任务在 10 秒后运行的事件
2. 如果某个类型的一个任务被调度，并且另一个相同的请求进来，则现有的未来任务的“执行时间”会被调整。

目前我正在使用在线程中操作的“ConcurrentQueue”进行此操作

public class ToDo
{
 public DateTime Expires { get; set; }
 public Action StuffToDo { get; set; }
}

然后是我的线程

public void MyWorkerThread(object parameters)
{
 while (!<check if cancellation requested>)
 {
   ToDo stuff;
   if (myConcurrentQueue.TryDequeue(out stuff))
   {
     if (DateTime.Now > stuff.Expires)
      {
        Task.StuffToDo.Invoke();
      }
     else 
      {
       // queue it back if it is not time to execute it
       //
        myConcurrentQueue.Enqueue(stuff);
      }
   }
 }
}

这是我将任务排队的事件处理程序

private ConcurrentDictionary<ToDo> _todoDictionary = new ConcurrentDictionary<ToDo>();
private ConcurrentQueue<ToDo> myConcurrentQueue = new ConcurrentQueue<ToDo>();
public void MyEventFired(MyEventArgs e)
{
 ToDo todo = null;

 if (_todoDictionary.ContainsKey(e.TaskType)) 
 {
   _todoDictionary.TryRemove(out todo);
   if (DateTime.Now >= task.Expires) 
   {
     todo = new ToDo();
     todo.StuffToDo = new Action(() => { /* stuff here */ });
   }   
 } 
 else
 {
   todo = new ToDo();
   todo.StuffToDo = new Action(() => { /* stuff here */ });
 }

 todo.Expires = DateTime.Now + TimeSpan.FromSeconds(10.0);

 _todoDictionary.Add(e.TaskType, todo);
 myConcurrentQueue.Enqueue(todo);
}

有人向我暗示，我可以使用 TPL 完成上述所有操作，而且我不需要工作线程，我可以使用“Task.Delay”。我仍在考虑如何处理它。任何想法将不胜感激。

这是我想做的事情 我希望根据 Task.Run 和/或 Task.Delay().ContinueWith 序列重写工作线程。

Answer 1

您当前的MyWorkerThread 代码正忙于旋转循环。它在 CPU 内核上驱动到 100%。您应该会听到 CPU 风扇因此而旋转的声音。

以下是我如何实现可重置延迟：

volatile int targetTicks = Environment.TickCount + (10 * 1000);

async Task WaitUntilTargetReachedAsync() {
 while (true) {
  var currentTicks = Environment.TickCount; //stabilize value
  var targetTicksLocal = targetTicks; //volatile read, stabilize value
  if (currentTicks >= targetTicksLocal) break; //Target reached.
  await Task.Delay(TimeSpan.FromMilliseconds(targetTicksLocal - currentTicks));
 }
}

WaitUntilTimeoutAsync() 将在达到targetTicks 时完成。您可以随时向targetTicks 添加时间，WaitUntilTimeoutAsync() 将进行调整。这样您就可以将计时器重置为现在加上 10 秒：

targetTicks = Environment.TickCount + (10 * 1000);

既然你有一个任务可以在你需要的时候完成，你可以根据它来采取行动：

targetTicks = Environment.TickCount + (10 * 1000); //Initial timer configuration.
await WaitUntilTimeoutAsync();
InvokeMyAction();