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

class Program
{
    static SemaphoreSlim semaphore = new SemaphoreSlim(3); // 最多3個(gè)并發(fā)

    static async Task Main()
    {
        var tasks = new Task[10];
        for (int i = 0; i < 10; i++)
        {
            int id = i;
            tasks[i] = Task.Run(() => DoWorkAsync(id));
        }

        await Task.WhenAll(tasks);
        Console.WriteLine("全部任務(wù)完成！");
    }

    static async Task DoWorkAsync(int id)
    {
        await semaphore.WaitAsync(); // 獲取許可
        try
        {
            Console.WriteLine($"任務(wù) {id} 開(kāi)始，當(dāng)前時(shí)間：{DateTime.Now:T}");
            await Task.Delay(1000); // 模擬工作
            Console.WriteLine($"任務(wù) {id} 結(jié)束。");
        }
        finally
        {
            semaphore.Release(); // 釋放許可
        }
    }
}

任務(wù) 0 開(kāi)始...
任務(wù) 1 開(kāi)始...
任務(wù) 2 開(kāi)始...
任務(wù) 3 等待中...
任務(wù) 0 結(jié)束。
任務(wù) 3 開(kāi)始...
...

using System;
using System.Net.Http;
using System.Threading;
using System.Threading.Tasks;

class WebCrawler
{
    static readonly HttpClient httpClient = new HttpClient();
    static readonly SemaphoreSlim semaphore = new SemaphoreSlim(5); // 最多5個(gè)并發(fā)

    static async Task Main()
    {
        var urls = new[]
        {
            "https://example.com",
            "https://dotnet.microsoft.com",
            "https://github.com",
            "https://openai.com",
            "https://google.com",
            "https://bing.com"
        };

        var tasks = new Task[urls.Length];
        for (int i = 0; i < urls.Length; i++)
        {
            string url = urls[i];
            tasks[i] = ProcessUrlAsync(url);
        }

        await Task.WhenAll(tasks);
        Console.WriteLine("所有請(qǐng)求完成！");
    }

    static async Task ProcessUrlAsync(string url)
    {
        await semaphore.WaitAsync();
        try
        {
            Console.WriteLine($"開(kāi)始請(qǐng)求：{url}");
            var response = await httpClient.GetAsync(url);
            Console.WriteLine($"{url} 返回狀態(tài)碼：{response.StatusCode}");
        }
        finally
        {
            semaphore.Release();
        }
    }
}

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

class FileWriter
{
    static SemaphoreSlim semaphore = new SemaphoreSlim(1); // 一次僅允許1個(gè)線程寫文件

    static async Task Main()
    {
        var tasks = new Task[5];
        for (int i = 0; i < 5; i++)
        {
            int id = i;
            tasks[i] = Task.Run(() => WriteLogAsync(id));
        }

        await Task.WhenAll(tasks);
        Console.WriteLine("寫入完成。");
    }

    static async Task WriteLogAsync(int id)
    {
        await semaphore.WaitAsync();
        try
        {
            await File.AppendAllTextAsync("output.txt", $"線程 {id} 在 {DateTime.Now}\n");
            Console.WriteLine($"線程 {id} 寫入完成");
        }
        finally
        {
            semaphore.Release();
        }
    }
}

if (await semaphore.WaitAsync(TimeSpan.FromSeconds(2)))
{
    try
    {
        Console.WriteLine("成功獲取資源。");
    }
    finally
    {
        semaphore.Release();
    }
}
else
{
    Console.WriteLine("等待超時(shí)，放棄操作。");
}

using System;
using System.Collections.Concurrent;
using System.Threading;
using System.Threading.Tasks;

class QueueProcessor
{
    static SemaphoreSlim semaphore = new SemaphoreSlim(3); // 同時(shí)處理3個(gè)任務(wù)
    static BlockingCollection<int> queue = new BlockingCollection<int>();

    static async Task Main()
    {
        // 模擬生產(chǎn)者
        Task.Run(() =>
        {
            for (int i = 0; i < 10; i++)
            {
                queue.Add(i);
                Console.WriteLine($"生產(chǎn)任務(wù) {i}");
                Thread.Sleep(200);
            }
            queue.CompleteAdding();
        });

        // 消費(fèi)者
        var consumers = new Task[3];
        for (int i = 0; i < consumers.Length; i++)
        {
            consumers[i] = Task.Run(() => ConsumeAsync(i));
        }

        await Task.WhenAll(consumers);
        Console.WriteLine("隊(duì)列處理完成。");
    }

    static async Task ConsumeAsync(int workerId)
    {
        foreach (var item in queue.GetConsumingEnumerable())
        {
            await semaphore.WaitAsync();
            try
            {
                Console.WriteLine($"工作線程 {workerId} 處理任務(wù) {item}");
                await Task.Delay(500);
            }
            finally
            {
                semaphore.Release();
            }
        }
    }
}