这是我的做法(虽然我不喜欢这个解决方案):
这个想法是有一个计时器,当它被触发时,它会检查所有挂起的操作是否超时。我创建了一个我的异步客户端实现的接口:
public interface ITimeoutable {
event Action<ITimeoutable, Operation> Begin;
event Action<ITimeoutable, Operation> End;
void DoTimeout(Operation operation);
}
其中 Operation 是一个枚举,定义为:
public enum Operation {
Connect,
Send,
Receive,
Disconnect
}
因此,客户端Begin
在启动异步操作时引发End
事件,并在完成时引发事件。另一方面,我创建了一个 TimeoutManager,它有一个异步客户端集合和一个包含操作及其启动时间的字典。创建新客户端时,它会注册到TimeoutManager
订阅事件的 . 使用TimeoutManager
aSystem.Threading.Timer
检查哪些操作超时。如果它有超时,那么它调用DoTimeout
方法(从ITimeoutable
接口)。
这是一个相当复杂的代码,我不喜欢它。但它有效。