C# Task异步编程的实现示例

// 无返回值的 Task
Task task = Task.Run(() => {
    Console.WriteLine("任务执行中");
});

// 有返回值的 Task<int>
Task<int> taskWithResult = Task.Run(() => {
    return 42;
});

// 使用 await（需在 async 方法中）
async Task ExecuteTaskAsync() {
    await Task.Run(() => {
        Console.WriteLine("任务完成");
    });
}

// 使用 Wait（阻塞当前线程）
Task task = Task.Run(() => {
    Console.WriteLine("任务完成");
});
task.Wait();

Task<int> task = Task.Run(() => {
    return 42;
});
int result = task.Result; // 阻塞直到任务完成
Console.WriteLine(result); // 输出 42

Task task = Task.Run(() => {
    throw new InvalidOperationException("任务出错");
});

try {
    task.Wait();
} catch (AggregateException ex) {
    foreach (var e in ex.InnerExceptions) {
        Console.WriteLine(e.Message);
    }
}

Task task1 = Task.Run(() => { /* 任务1 */ });
Task task2 = Task.Run(() => { /* 任务2 */ });

// 等待所有任务完成
await Task.WhenAll(task1, task2);

// 等待任意一个任务完成
await Task.WhenAny(task1, task2);

CancellationTokenSource cts = new CancellationTokenSource();
Task task = Task.Run(() => {
    while (true) {
        if (cts.Token.IsCancellationRequested) {
            break; // 取消任务
        }
    }
}, cts.Token);

// 取消任务
cts.Cancel();

async Task<int> GetDataAsync() {
    await Task.Delay(1000); // 模拟异步操作
    return 42;
}

async Task Main() {
    int result = await GetDataAsync();
    Console.WriteLine(result);
}