主页 / 问题 / 1439635
Accepted
Сергей
Asked:2022-08-16 03:57:44 +0000 UTC2022-08-16 03:57:44 +0000 UTC

如果至少有一个任务结束，如何关闭所有任务

  • 772

有decimal一个参数。假设它等于 10。有Task一段时间100ms将它减少0.1. 一旦参数变得等于1，任务应该结束并且参数不应该再减少。如果Task只有一个，则可以正常工作。但如果它们是2, 3, 100...，那么参数最终会变小1。我尝试使用CancellationToken来完成所有任务，但结果还是一样。我的代码：

    class Program
    {
        static decimal param = 108;
        static CancellationTokenSource cancelTokenSource = new CancellationTokenSource();
        static CancellationToken token;

        static void Main(string[] args)
        {
            int tasksCount = 16;
            token = cancelTokenSource.Token;

            Console.WriteLine("Start Param = {0}", param);
            Console.WriteLine("Tasks Count = {0}", tasksCount);

            var tasksList = new List<Task>();
            for (var i = 0; i < tasksCount; i++)
            {
                Task task = new Task(Decrementation, token);
                tasksList.Add(task);
            }
            tasksList.ForEach(x => x.Start());
            Task.WaitAny(tasksList.ToArray());

            Console.WriteLine("Result = {0}", param);
            Console.Read();
        }

        private static void Decrementation()
        {
            while (true)
            {
                if (token.IsCancellationRequested)
                {
                    break;
                }

                if (CanTakeMore())
                {
                    Task.Delay(100);
                    param = param - 0.1m;
                }
                else
                {
                    cancelTokenSource.Cancel();
                    return;
                }
            }
        }

        private static bool CanTakeMore()
        {
            if (param > 1)
            {
                return true;
            }
            else
            {
                return false;
            }
        }
    }

输出不同，但始终小于 1。

在此处输入图像描述

我究竟做错了什么？

c# .net

1 个回答

  1. Best Answer

    结论不一样

    由于此代码不是线程安全的，因此必须在幕后进行减法和值检查。

    • Task.Delay没有就行不通await
    • Task根本不应该使用构造函数，这是创建任务的过时方法
    • CancellationTokenSource这IDisposable是要使用的using
    • 避免多线程中的全局资源、字段和属性，使用方法参数和返回值
    • 使用同步组合器WaitAny也不WaitAll值得，还有异步

    让我们添加一些线程安全性。如果一切都正确完成，甚至不需要取消令牌，如果所有方法本身都安全完成，则无需安排黄油。

    class Program
{
    static decimal param = 108;
    static readonly object syncRoot = new object();

    static asynс Task Main(string[] args)
    {
        int tasksCount = 16;

        Console.WriteLine($"Start Param = {param}");
        Console.WriteLine($"Tasks Count = {tasksCount}");
        
        var tasks = new List<Task>();
        for (int i = 0; i < tasksCount; i++)
        {
            Task task = Task.Run(Decrementation);
            tasks.Add(task);
        }
            
        await Task.WhenAll(tasks);

        Console.WriteLine($"Result = {param}");
        Console.ReadKey();
    }

    private static void Decrementation()
    {
        while (true)
        {
            lock (syncRoot)
            {
                if (CanTakeMore()) 
                    param -= 0.1m;
                else
                    return;
            }
            Thread.Sleep(100); // здесь бы имел смысл токен отмены и await Task.Delay, если бы ожидание было длительным
                               // напишите коммент, нсли надо показать асинхронный код с отменой
        }
    }

    private static bool CanTakeMore()
    {
        return param > 1;
    }
}
    • 1

相关问题