在 x 秒后触发事件，但在执行之前也将其取消

Question

我正在开发一个 Web API（效果很好）。少了什么东西？ 这是Get Action 的示例代码：

public IEnumerable<xxxx> Get()
{           
    IEnumerable<xxxx> yyyy = new List<xxxx>();
    //get yyyy from database
    timer = new Timer();
    timer.AutoReset = true;
    timer.Enabled = true;
    timer.Interval = 5000; //miliseconds
    timer.Elapsed += timer_Elapsed;
    timer.Start();
    return yyyy;
}
void timer_Elapsed(object sender, ElapsedEventArgs e)
{
    //code to be executed when timer elapses...
}

因此，一旦收到请求，计时器将被初始化并以 5 秒的间隔触发 Elapsed 事件。在下一个后续请求中，这将继续......

预期的行为是这样的：

1. 初始化请求 -1
2. 初始化定时器 -1
3. 如果在 5 秒内收到来自同一客户端的另一个请求，则计时器不得触发 elapsed 事件。
4. 如果在 5 秒内未收到来自同一客户端的请求，则计时器应超时并触发事件。

而且计时器与客户端无关。

这是与此相关的进一步业务场景...... 我正在开发一个 Web API，它在打开时将被电子设备使用。只要电源可用，设备就会一直发送其 ON 状态。一旦用户关闭开关，对服务器的请求就会停止。

无论设备是开还是关，这些状态都会更新到数据库中。现在更棘手的部分是识别设备何时关闭（很复杂，因为如果设备停止发送任何请求，服务器不知道任何事情）。所以每个设备都有一个单独的计时器。

Answer 1

首先，感谢@Patrick Hofman 指导我并跳出框框思考...... 我实现了一个内部有静态属性的类。

public class DeviceContainer
{
    public static List<DevTimer> timers=new List<DevTimer>();
}
public class DevTimer:Timer
{
    public string Identifier {get; set;}
    public bool IsInUse{get; set;}
}

然后在上面的代码（有问题）中，我做了以下更改：

public IEnumerable<xxxx> Get(string Id)
{        
    //Check if timer exists in
    if(!DeviceContainer.timers.Any(s=>s.Identifier.Equals(Id)))
    {
         //Create new object of timer, assign identifier =Id, 
         //set interval and initialize it. add it to collection as
         var timer = new DevTimer();
         timer.AutoReset = true;
         timer.Enabled = true;
         timer.Interval = 5000; //miliseconds
         timer.Elapsed += timer_Elapsed;
         timer.IsInUse=true;
         timer.Identifier=Id;             
         DeviceContainer.timers.Add(timer);
         timer.Start();
    }
    else
    {
         //Code to stop the existing timer and start it again.
         var _timer=DeviceContainer.timers.FirstOrDefault(s=>s.Identifier.Equals(Id)) 
                      as DevTimer;
         _timer.Stop();
         _timer.Start();
    }        

}
void timer_Elapsed(object sender, ElapsedEventArgs e)
{
    //code that will turn off the device in DB
}

我没有发布整个代码，因为这不是这里的目的。

Answer 2

我会为此使用 Microsoft 的响应式框架。

代码如下：

IEnumerable<xxxx> yyyy = new List<xxxx>();

Subject<Unit> clientRequestArrived = new Subject<Unit>();

IDisposable subscription =
    clientRequestArrived
        .Select(_ => Observable.Interval(TimeSpan.FromSeconds(5.0)))
        .Switch()
        .Subscribe(_ =>
        {
            //code to be executed when timer elapses...
            //directly access `yyyy` here
        });

您需要做的就是每次收到用户请求时调用clientRequestArrived.OnNext(Unit.Default);，这足以让此代码重置计时器。

如果您想完全停止计时器，只需致电subscription.Dispose()。