北府南楼 2021-12-02 17:21 采纳率: 66.7%
浏览 20
已结题

一个有关于Task是否完全取消的问题,请解惑

问题遇到的现象和发生背景

我原本的想法是,一个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次。

我的解答思路和尝试过的方法
我想要达到的结果
  • 写回答

2条回答 默认 最新

  • 於黾 2021-12-02 17:31
    关注

    for (iik = 0; iik < 1000; iik++)
    {
    Thread.Sleep(200);
    你这一下就sleep 200秒,再加上一开始sleep(1000),那么每隔10秒启动一个线程,等21次后才有反应,那不是正好吗
    你把timer改成100,那就更明显了,一开始21秒完全没反应,因为都在sleep嘛,然后接下来的21秒就一直在输出。

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论 编辑记录
查看更多回答(1条)

报告相同问题?

问题事件

  • 系统已结题 12月11日
  • 已采纳回答 12月3日
  • 创建了问题 12月2日

悬赏问题

  • ¥20 机器学习能否像多层线性模型一样处理嵌套数据
  • ¥20 西门子S7-Graph,S7-300,梯形图
  • ¥50 用易语言http 访问不了网页
  • ¥50 safari浏览器fetch提交数据后数据丢失问题
  • ¥15 matlab不知道怎么改,求解答!!
  • ¥15 永磁直线电机的电流环pi调不出来
  • ¥15 用stata实现聚类的代码
  • ¥15 请问paddlehub能支持移动端开发吗?在Android studio上该如何部署?
  • ¥20 docker里部署springboot项目,访问不到扬声器
  • ¥15 netty整合springboot之后自动重连失效