我原本的想法是,一个timer(Interval=1000)间隔执行一个Task,如下:
Task TaskTimeOut =null;
Task TaskWrite=null;
int iik =0;
//RecordMsg 是打印信息
private void Myelapsed(object sender, ElapsedEventArgs e)
{
TaskTimeOut = Task.Factory.StartNew(async () =>
{
WriteKBTokenSource = new CancellationTokenSource();
WriteKBTokenSource.Token.Register(()=>
{
RecordMsg(iik.ToString() + " token取消...");
});
if (TaskWrite!=null)
{
RecordMsg(TaskWriteKanBan.Status.ToString() + "xxxxx...");
}
TaskWrite= null;
TaskWrite= Task.Run(new Action(() =>
{
WriteKBTokenSource.Token.ThrowIfCancellationRequested();
RecordMsg(string.Format("开始..................................."));
Thread.Sleep(1000);
WriteKBTokenSource.Token.ThrowIfCancellationRequested();
//执行一个逻辑操作....
iik = 0;
WriteKBTokenSource.Token.ThrowIfCancellationRequested();
for (iik = 0; iik < 1000; iik++)
{
Thread.Sleep(200);
}
WriteKBTokenSource.Token.ThrowIfCancellationRequested();
RecordMsg(string.Format("写入结束......................"));
}
}), WriteKBTokenSource.Token);
if (await Task.WhenAny(TaskWrite, Task.Delay(TimeSpan.FromSeconds(2))) != TaskWrite)
{
RecordMsg(TaskWrite.Status.ToString() + " yyyyyy...");
WriteKBTokenSource.Cancel();
RecordMsg("写入数据的线程超时2s未完成,已取消...");
RecordMsg(TaskWrite.IsCompleted.ToString() + " 已取消...");
RecordMsg(TaskWrite.Status.ToString() + " zzzzzz...");
}
});
}
TaskWrite的状态只要执行过第一遍以后,就一直是running,三个打印该状态的地方,全部打印出来的是running;
一开始执行的时候,“写入结束“这句话不会打印,但每隔执行个10-20次后,就会连续打印这句话出来,大概刚好是10-20次。
for (iik = 0; iik < 1000; iik++)
{
Thread.Sleep(200);
你这一下就sleep 200秒,再加上一开始sleep(1000),那么每隔10秒启动一个线程,等21次后才有反应,那不是正好吗
你把timer改成100,那就更明显了,一开始21秒完全没反应,因为都在sleep嘛,然后接下来的21秒就一直在输出。
timer的间隔写错了,是10s的,少写了个0.