正文

C# 线程传递参数技巧：掌握四种方法实现高效线程间数据传递

/0 浏览量
1028

在C#中，线程间的数据传递是一个常见的需求，尤其是在多线程编程中，为了提高效率，我们需要掌握一些技巧来实现高效的数据传递。下面，我将详细介绍四种常用的方法来实现C#线程间的参数传递。

方法一：使用委托和事件

委托（Delegate）和事件（Event）是C#中处理异步编程和线程间通信的强大工具。通过定义一个委托，可以在不同的线程之间传递参数。

示例代码：

public delegate void DataChangedHandler(string data);

public class ThreadSafeClass
{
    public event DataChangedHandler DataChanged;

    public void SetData(string data)
    {
        // 在线程安全的环境下设置数据
        lock (this)
        {
            // 更新数据
            this.data = data;

            // 触发事件
            DataChanged?.Invoke(data);
        }
    }
}

public class WorkerThread
{
    private ThreadSafeClass threadSafeClass;

    public WorkerThread(ThreadSafeClass threadSafeClass)
    {
        this.threadSafeClass = threadSafeClass;
        threadSafeClass.DataChanged += DataReceived;
    }

    public void Start()
    {
        // 在新线程中启动工作
        new Thread(() =>
        {
            // 模拟数据处理
            string data = "Processed Data";
            threadSafeClass.SetData(data);
        }).Start();
    }

    private void DataReceived(string data)
    {
        // 处理接收到的数据
        Console.WriteLine("Received data: " + data);
    }
}

方法二：使用静态变量

在C#中，静态变量属于类，而不是对象实例。这意味着，无论创建多少线程，静态变量的值都是共享的。

示例代码：

public class SharedData
{
    public static string Data { get; set; }
}

public class WorkerThread
{
    public void Start()
    {
        // 在新线程中启动工作
        new Thread(() =>
        {
            // 模拟数据处理
            string data = "Processed Data";
            SharedData.Data = data;

            // 假设需要等待其他线程处理数据
            Thread.Sleep(1000);

            // 处理接收到的数据
            Console.WriteLine("Received data: " + SharedData.Data);
        }).Start();
    }
}

方法三：使用内存映射文件

内存映射文件（Memory-Mapped File）是一种高效的线程间通信方式，适用于大块数据的传递。

示例代码：

public class MemoryMappedFileExample
{
    public static void Main()
    {
        using (var mmf = MemoryMappedFile.CreateOrOpen("MySharedMemory", 1024))
        {
            using (var view = mmf.CreateViewAccessor())
            {
                // 读写共享内存
                view.Write(0, Encoding.UTF8.GetBytes("Hello, World!"));
                string data = Encoding.UTF8.GetString(view.ReadArray<string>(0, 14));
                Console.WriteLine("Received data: " + data);
            }
        }
    }
}

方法四：使用并发集合

C#中的并发集合（如ConcurrentQueue、ConcurrentBag等）可以方便地在线程之间传递数据。

示例代码：

public class ConcurrentQueueExample
{
    private ConcurrentQueue<string> queue = new ConcurrentQueue<string>();

    public void Start()
    {
        // 在新线程中启动工作
        new Thread(() =>
        {
            // 模拟数据处理
            string data = "Processed Data";
            queue.Enqueue(data);

            // 假设需要等待其他线程处理数据
            Thread.Sleep(1000);

            // 处理接收到的数据
            while (queue.TryDequeue(out string receivedData))
            {
                Console.WriteLine("Received data: " + receivedData);
            }
        }).Start();
    }
}

通过以上四种方法，我们可以根据实际需求选择合适的方式来实现C#线程间的数据传递。在实际开发中，灵活运用这些技巧，可以有效提高程序的效率和稳定性。

-- 展开阅读全文 --