C# Task取消暂停的实现

using System;
using System.Threading;
using System.Threading.Tasks;

class Program
{
    static async Task Main()
    {
        var cts = new CancellationTokenSource();
        var token = cts.Token;

        var task = Task.Run(() => DoWork(token), token);

        // 模拟一段时间后取消操作
        Thread.Sleep(2000);
        cts.Cancel();

        try
        {
            await task; // 如果操作被取消，这里会抛出异常
        }
        catch (OperationCanceledException)
        {
            Console.WriteLine("Operation was canceled.");
        }
    }

    static void DoWork(CancellationToken token)
    {
        for (int i = 0; i < 10; i++)
        {
            if (token.IsCancellationRequested)
            {
                Console.WriteLine("Cancellation requested.");
                return;
            }
            Thread.Sleep(500); // 模拟工作
            Console.WriteLine($"Working... {i}");
        }
    }
}

static void DoWork(CancellationToken token)
{
    for (int i = 0; i < 10; i++)
    {
        token.ThrowIfCancellationRequested(); // 如果取消请求已发送，则抛出异常
        
        Console.WriteLine($"DoWork: Working {i + 1}...");
        Thread.Sleep(500); // 模拟耗时操作
    }

    Console.WriteLine("DoWork: Work completed."); // 这行代码实际上不会被执行，因为循环会在某个点抛出异常
}

using System;
using System.Threading;
using System.Threading.Tasks;

class Program
{
    static ManualResetEvent resetEvent = new ManualResetEvent(false);

    static async Task Main(string[] args)
    {
        // 创建并启动多个Task
        Task[] tasks = new Task[3];
        for (int i = 0; i < tasks.Length; i++)
        {
            int taskId = i; // 捕获循环变量
            tasks[i] = Task.Run(() => Worker(taskId));
        }

        // 模拟一些工作...
        Console.WriteLine("Main thread is doing some work...");
        await Task.Delay(2000); // 异步等待

        // 设置事件，允许所有等待的Task继续执行
        Console.WriteLine("Setting the event to allow all tasks to continue...");
        resetEvent.Set();

        // 等待所有Task完成
        await Task.WhenAll(tasks);

        Console.WriteLine("All tasks have completed.");
    }

    static void Worker(int taskId)
    {
        Console.WriteLine($"Task {taskId} is waiting...");
        resetEvent.WaitOne(); // 等待事件被设置
        Console.WriteLine($"Task {taskId} continues...");

        // 模拟一些工作...
        Thread.Sleep(1000); // 注意：在async方法中通常使用await Task.Delay()
    }
}

using System;
using System.Threading.Tasks;

class Program
{
    static Task completionSignal = new TaskCompletionSource<bool>().Task;

    static async Task Main(string[] args)
    {
        // 创建并启动多个Task
        Task[] tasks = new Task[3];
        for (int i = 0; i < tasks.Length; i++)
        {
            tasks[i] = Task.Run(async () => await Worker(i));
        }

        // 模拟一些工作...
        Console.WriteLine("Main thread is doing some work...");
        await Task.Delay(2000);

        // 设置事件，允许所有等待的Task继续执行
        ((TaskCompletionSource<bool>)completionSignal.Source).SetResult(true);

        // 等待所有Task完成
        await Task.WhenAll(tasks);

        Console.WriteLine("All tasks have completed.");
    }

    static async Task Worker(int taskId)
    {
        Console.WriteLine($"Task {taskId} is waiting...");
        await completionSignal; // 等待事件被设置
        Console.WriteLine($"Task {taskId} continues...");

        // 模拟一些异步工作...
        await Task.Delay(1000);
    }
}

using System;
using System.Threading;
using System.Threading.Tasks;

class Program
{
    static ManualResetEvent pauseEvent = new ManualResetEvent(true); // 初始化为已设置状态，即线程不暂停

    static void Main(string[] args)
    {
        // 启动工作线程
        Task.Run(WorkerThread);

        // 控制台输入来控制暂停和恢复
        Console.WriteLine("Press 'p' to pause, 'r' to resume, or 'q' to quit.");
        while (true)
        {
            var key = Console.ReadKey(true).KeyChar;
            switch (key)
            {
                case 'p':
                    pauseEvent.Reset(); // 暂停线程
                    Console.WriteLine("Worker thread paused.");
                    break;
                case 'r':
                    pauseEvent.Set(); // 恢复线程
                    Console.WriteLine("Worker thread resumed.");
                    break;
                case 'q':
                    // 这里需要一种方式来通知工作线程优雅地退出，但在这个简单示例中我们直接退出程序
                    Environment.Exit(0);
                    break;
            }
        }
    }

    static void WorkerThread()
    {
        while (true)
        {
            // 等待暂停事件
            pauseEvent.WaitOne();

            // 执行工作...
            Console.WriteLine("Worker thread is working...");

            // 模拟工作耗时
            Thread.Sleep(500);

            // 注意：在真实场景中，你可能不需要在每次循环迭代中都调用 WaitOne，
            // 除非你真的希望每次迭代都检查暂停状态。
            // 在这个示例中，我们只是为了演示而这样做。
        }
    }
}