C#中实现跨线程写入的示例代码
<div id="navCategory"><h5 class="catalogue">目录</h5><ul class="first_class_ul"><li>方案核心思路</li><li>完整代码实现</li><li>关键改进解析</li><ul class="second_class_ul"><li>1.跨线程写入请求的提交</li><li>2.专用写入线程处理队列</li><li>3.双重信号确保原子性</li><li>4.线程安全停止机制</li></ul><li>运行效果</li><ul class="second_class_ul"></ul><li>方案优势</li><ul class="second_class_ul"></ul><li>适用场景</li><ul class="second_class_ul"></ul><li>注意事项</li><ul class="second_class_ul"></ul></ul></div><p class="maodian"></p><h2>方案核心思路</h2><ul><li><strong>写入请求队列</strong>：使用 <code>ConcurrentQueue</code> 接收来自任意线程的写入请求。</li><li><strong>专用写入线程</strong>：由独立线程处理队列中的写入操作，确保顺序执行。</li><li><strong>双信号机制</strong>：通过 <code>ManualResetEventSlim</code> 控制读取线程的暂停与恢复。</li><li><strong>线程安全确认</strong>：确保多个线程同时触发写入时，不会导致竞态条件。</li></ul>
<p class="maodian"></p><h2>完整代码实现</h2>
<div class="jb51code"><pre class="brush:csharp;">using System;
using System.Collections.Concurrent;
using System.Threading;
public class CrossThreadReadWriteController
{
// 控制读取线程暂停和恢复的信号
private readonly ManualResetEventSlim _pauseRequest = new ManualResetEventSlim(false);
// 读取线程确认已暂停的信号
private readonly ManualResetEventSlim _pausedConfirmed = new ManualResetEventSlim(false);
// 写入请求队列（线程安全）
private readonly ConcurrentQueue<Action> _writeQueue = new ConcurrentQueue<Action>();
// 停止标志
private volatile bool _stopRequested = false;
// 写入专用线程
private Thread _writeThread;
public CrossThreadReadWriteController()
{
// 启动写入专用线程
_writeThread = new Thread(ProcessWriteQueue);
_writeThread.Start();
}
// 读取线程的循环任务
public void ReadLoop()
{
while (!_stopRequested)
{
// 检查是否需要暂停
if (_pauseRequest.IsSet)
{
// 确认已暂停，并等待恢复信号
_pausedConfirmed.Set();
_pauseRequest.Wait();
_pausedConfirmed.Reset();
}
// 模拟读取操作
Console.WriteLine($" {DateTime.Now:HH:mm:ss.fff} - Reading data...");
Thread.Sleep(1000); // 模拟耗时操作
}
Console.WriteLine(" Thread stopped.");
}
// 处理写入队列的专用线程
private void ProcessWriteQueue()
{
while (!_stopRequested || !_writeQueue.IsEmpty)
{
if (_writeQueue.TryDequeue(out var writeAction))
{
// 触发暂停读取线程
RequestPause();
// 执行写入操作
writeAction.Invoke();
// 恢复读取线程
ResumeRead();
}
else
{
Thread.Sleep(50); // 队列为空时短暂休眠
}
}
Console.WriteLine(" Thread stopped.");
}
// 跨线程提交写入请求
public void SubmitWriteCommand(Action writeAction)
{
_writeQueue.Enqueue(writeAction);
}
// 请求暂停读取线程（线程安全）
private void RequestPause()
{
_pauseRequest.Set();
_pausedConfirmed.Wait(); // 等待读取线程确认暂停
}
// 恢复读取线程（线程安全）
private void ResumeRead()
{
_pauseRequest.Reset();
}
// 停止所有线程
public void Stop()
{
_stopRequested = true;
_pauseRequest.Set(); // 确保读取线程退出等待
_writeThread.Join(); // 等待写入线程结束
}
}
// 使用示例
public class Program
{
public static void Main()
{
var controller = new CrossThreadReadWriteController();
// 启动读取线程
var readThread = new Thread(controller.ReadLoop);
readThread.Start();
// 模拟多个线程触发写入操作
for (int i = 0; i < 3; i++)
{
var threadId = i;
new Thread(() =>
{
controller.SubmitWriteCommand(() =>
{
Console.WriteLine($" {DateTime.Now:HH:mm:ss.fff} - Writing data...");
Thread.Sleep(500); // 模拟耗时操作
});
}).Start();
}
Thread.Sleep(5000); // 等待所有写入完成
controller.Stop();
readThread.Join();
Console.WriteLine("Main thread exited.");
}
}</pre></div>
<p class="maodian"></p><h2>关键改进解析</h2>
<p class="maodian"></p><h3>1.跨线程写入请求的提交</h3>
<p>通过 <code>SubmitWriteCommand</code> 方法，任何线程均可提交写入操作：</p>
<div class="jb51code"><pre class="brush:csharp;">public void SubmitWriteCommand(Action writeAction)
{
_writeQueue.Enqueue(writeAction); // 线程安全入队
}</pre></div>
<p class="maodian"></p><h3>2.专用写入线程处理队列</h3>
<p>写入操作由独立线程顺序处理，避免多线程并发写入冲突：</p>
<div class="jb51code"><pre class="brush:csharp;">private void ProcessWriteQueue()
{
while (!_stopRequested || !_writeQueue.IsEmpty)
{
if (_writeQueue.TryDequeue(out var writeAction))
{
RequestPause(); // 暂停读取线程
writeAction(); // 执行写入
ResumeRead(); // 恢复读取线程
}
}
}</pre></div>
<p class="maodian"></p><h3>3.双重信号确保原子性</h3>
<p>通过 <code>RequestPause</code> 和 <code>ResumeRead</code> 方法封装暂停与恢复逻辑：</p>
<div class="jb51code"><pre class="brush:csharp;">private void RequestPause()
{
_pauseRequest.Set(); // 发送暂停信号
_pausedConfirmed.Wait();// 阻塞等待读取线程确认暂停
}</pre></div>
<p class="maodian"></p><h3>4.线程安全停止机制</h3>
<p>通过 <code>_stopRequested</code> 标志和队列检查确保安全退出：</p>
<div class="jb51code"><pre class="brush:csharp;">public void Stop()
{
_stopRequested = true;
_writeThread.Join(); // 等待写入线程处理完队列
}</pre></div>
<p class="maodian"></p><h2>运行效果</h2>
<blockquote><p> 14:30:01.123 - Reading data...<br /> 14:30:02.124 - Reading data...<br /> 14:30:03.125 - Writing data...<br /> 14:30:03.626 - Reading data...<br /> 14:30:04.127 - Writing data...<br /> 14:30:04.628 - Reading data...<br /> 14:30:05.129 - Writing data...<br />Main thread exited.</p></blockquote>
<p class="maodian"></p><h2>方案优势</h2>
<table><thead><tr><th>特性</th><th>说明</th></tr></thead><tbody><tr><td>多线程安全</td><td>通过 ConcurrentQueue 和信号量，支持任意线程触发写入操作。</td></tr><tr><td>顺序执行</td><td>写入操作由专用线程顺序处理，避免并发冲突。</td></tr><tr><td>无锁读取</td><td>读取线程在非写入状态下完全无锁，最大化性能。</td></tr><tr><td>精准控制</td><td>通过双信号机制确保写入操作执行期间读取线程完全暂停。</td></tr></tbody></table>
<p class="maodian"></p><h2>适用场景</h2>
<ul><li><strong>分布式任务调度</strong>：多个工作线程提交写入请求，由中心线程处理。</li><li><strong>实时数据采集</strong>：采集线程持续读取数据，外部线程动态更新配置。</li><li><strong>高并发服务</strong>：如网络服务器，处理来自不同客户端的并发更新操作。</li></ul>
<p class="maodian"></p><h2>注意事项</h2>
<ul><li><strong>队列积压风险</strong>：若写入操作频率过高，需监控队列长度或添加背压机制。</li><li><strong>异常处理</strong>：在写入操作中需捕获异常，避免导致写入线程崩溃。</li><li><strong>性能调优</strong>：可根据场景调整 <code>Thread.Sleep</code> 时间或使用无等待策略。</li></ul>
<p>到此这篇关于C#中实现跨线程写入的示例代码的文章就介绍到这了,更多相关C# 跨线程写入内容请搜索琼殿技术社区以前的文章或继续浏览下面的相关文章希望大家以后多多支持琼殿技术社区！</p>
<div class="art_xg">
<b>您可能感兴趣的文章:</b><ul><li>C#中跨线程访问控件的实现方法</li><li>C# winform 窗体控件跨线程访问的实现</li><li>C# winform跨线程操作控件的实现</li><li>C#多线程异步执行和跨线程访问控件Helper</li><li>C#-WinForm跨线程修改UI界面的示例</li><li>浅谈C#跨线程调用窗体控件(比如TextBox)引发的线程安全问题</li><li>C#多线程与跨线程访问界面控件的方法</li><li>C#实现跨线程操作控件方法</li><li>C#之WinForm跨线程访问控件实例</li><li>C#中跨线程访问控件问题解决方案分享</li></ul>
</div>
</div>
<!--endmain-->
頁:
[1]