c#中如何处理单线程任务 - 问答

在C#中，处理单线程任务通常意味着在一个线程上执行一系列操作，而不是并行执行多个任务。这可以通过使用同步方法和阻塞调用来实现。下面是一些处理单线程任务的方法：

使用同步方法：C#中的许多方法都是同步的，这意味着它们会阻塞当前线程，直到操作完成。例如，使用Thread.Sleep方法暂停当前线程：

using System;
using System.Threading;

class Program
{
    static void Main()
    {
        Console.WriteLine("Starting...");
        Thread.Sleep(2000); // 暂停2秒
        Console.WriteLine("Finished.");
    }
}

使用阻塞集合：BlockingCollection<T>类提供了一个线程安全的集合，可以在生产者和消费者之间传输数据。当没有数据可用时，消费者线程将阻塞，直到有数据可用。

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

class Program
{
    static void Main()
    {
        var blockingCollection = new BlockingCollection<int>();

        var producer = new Thread(() =>
        {
            for (int i = 0; i < 5; i++)
            {
                blockingCollection.Add(i);
                Thread.Sleep(500);
            }
            blockingCollection.CompleteAdding();
        });

        var consumer = new Thread(() =>
        {
            while (!blockingCollection.IsCompleted)
            {
                if (blockingCollection.TryTake(out int item))
                {
                    Console.WriteLine($"Processed: {item}");
                }
            }
        });

        producer.Start();
        consumer.Start();

        producer.Join();
        consumer.Join();
    }
}

使用Monitor或Mutex进行同步：这些类提供了同步原语，允许您在代码中创建临界区，确保在同一时间只有一个线程可以访问共享资源。

using System;
using System.Threading;

class Program
{
    private static readonly object _lockObject = new object();
    private static int _counter = 0;

    static void Main()
    {
        var thread1 = new Thread(IncrementCounter);
        var thread2 = new Thread(IncrementCounter);

        thread1.Start();
        thread2.Start();

        thread1.Join();
        thread2.Join();

        Console.WriteLine($"Counter: {_counter}");
    }

    static void IncrementCounter()
    {
        for (int i = 0; i < 1000; i++)
        {
            lock (_lockObject)
            {
                _counter++;
            }
        }
    }
}

这些方法展示了如何在C#中处理单线程任务。请注意，这些示例仅用于演示目的，实际应用程序可能需要更复杂的逻辑和错误处理。

0 赞

0 踩