北府南楼 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日

悬赏问题

  • ¥15 java业务性能问题求解(sql,业务设计相关)
  • ¥15 52810 尾椎c三个a 写蓝牙地址
  • ¥15 elmos524.33 eeprom的读写问题
  • ¥15 使用Java milo连接Kepserver服务端报错?
  • ¥15 用ADS设计一款的射频功率放大器
  • ¥15 怎么求交点连线的理论解?
  • ¥20 软件开发方法学习来了
  • ¥15 微信小程序商城如何实现多商户收款 平台分润抽成
  • ¥15 HC32L176调试了一个通过TIMER5+DMA驱动WS2812B
  • ¥15 关于自相关函数法和周期图法实现对随机信号的功率谱估计的matlab程序运行的问题,请各位专家解答!