问题遇到的现象和发生背景
我原本的想法是,一个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次。