C#多线程处理多个队列的数据(交叉线程访问及Invoke方法使用)


C#多线程处理多个队列的数据


public static void Testing(Form sender, DelegateShowStateInfo method)
{
   _StateMethod = method;
   _OwnerForm = sender;
   _Exit = false;
   
   ThreadPool.QueueUserWorkItem(MainTestThread);
   ThreadPool.QueueUserWorkItem(Queue1Thread); //啟動Queue1線程
   ThreadPool.QueueUserWorkItem(Queue2Thread); //啟動Queue2線程
}


// 来源:www.CSFramework.com, C/S结构框架学习网




贴图图片



using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using System.Collections;
using System.Windows.Forms;

// C/S框架网 www.csframework.com
namespace ThredProcessQueue
{
   //用于顯示狀態的代理方法類型定義
   public delegate void DelegateShowStateInfo(string state);
   
   /// <summary>
   /// 測試器
   /// </summary>
   public class QueueTester
   {
      private static bool _Exit = false; //標記是否已中斷測試程序
      private static Form _OwnerForm; //測試的窗體
      private static DelegateShowStateInfo _StateMethod;
      
      private static IList _Queue1 = new ArrayList(); //Queue1的數據
      private static IList _Queue2 = new ArrayList(); //Queue2的數據
      private static IList _Queue3 = new ArrayList(); //Queue3的數據
      
      
      public static void StopThread()
      {
         _Exit = true;
         _OwnerForm = null;
      }
      
      public static void Testing(Form sender, DelegateShowStateInfo method)
      {
         _StateMethod = method;
         _OwnerForm = sender;
         _Exit = false;
         
         ThreadPool.QueueUserWorkItem(MainTestThread);
         ThreadPool.QueueUserWorkItem(Queue1Thread); //啟動Queue1線程
         ThreadPool.QueueUserWorkItem(Queue2Thread); //啟動Queue2線程
      }
      
      //測試用的主線程,循環向隊列1中壓入數據。
      public static void MainTestThread(object state)
      {
         Random R = new Random(1);
         double V = 0;
         
         while (_Exit == false)
         {
            //在while(true)里一直对数据进行读取,然后放到queue1中,
            //与此同时如果queue1中有数据,则线程1就开启
            
            //臨時數據,隨機數
            V = R.NextDouble();
            
            _Queue1.Add(V); //把數據插入到隊列1
            Application.DoEvents();
            
            ShowState();
            
            Thread.Sleep(100);//生成隨機數太快,為了看清效果,暫停n毫秒
         }
      }
      
      
      //对queue1中的数据进行处理,处理后放到queue2中
      public static void Queue1Thread(object state)
      {
         while (_Exit == false)
         {
            while (_Queue1.Count > 0)
            {
               //对queue1中的数据进行处理,处理后放到queue2中
               _Queue2.Add(_Queue1[0]);
               _Queue1.RemoveAt(0);
               Application.DoEvents();
               
               ShowState();
            }
         }
      }
      
      //对queue2中的数据进行处理,处理后放到queue3中
      public static void Queue2Thread(object state)
      {
         while (_Exit == false)
         {
            while (_Queue2.Count > 0)
            {
               //对queue1中的数据进行处理,处理后放到queue2中
               _Queue3.Add(_Queue2[0]);
               _Queue2.RemoveAt(0);
               Application.DoEvents();
               
               ShowState();
            }
         }
      }
      
      //用于監視各隊列狀態的線程
      public static void ShowState()
      {
         string stateInfo =
         QueueTester._Queue1.Count.ToString() " -> "
         QueueTester._Queue2.Count.ToString() " -> "
         QueueTester._Queue3.Count.ToString();
         
         try
         {
            if (_OwnerForm != null)
            {
               _OwnerForm.Invoke(_StateMethod, stateInfo);
               Application.DoEvents();
            }
         }
         catch
         {
            
         }
      }
      
   }
   
}


// 来源:www.CSFramework.com, C/S结构框架学习网


版权声明:本文为开发框架文库发布内容,转载请附上原文出处连接
C/S框架网
上一篇:Fast Report 加载类型库DLL出错解决方法
下一篇:C# 模拟VisualStudio窗体设计器拖放控件
评论列表

发表评论

评论内容
昵称:
关联文章

C#线处理数据(交叉线访问Invoke方法使用)
C#线异步处理数据通用界面窗体(frmThreadOperating)
C#异步操作等待窗体,异步线处理数据通用界面(frmThreadOperating)
C#.Net使用线池(ThreadPool)与专用线(Thread)
C#异步编程(线
C# 线入门 - 开发实例
C#线使用读写锁ReaderWriterLockSlim同步写入文件
尝试释放正在使用RCW,活动线或其他线上正在使用该RCW
.NET5 HttpClient线并发请求阻塞“发生一个或错误”解决方案
C# Winform 使用SUM CASE WHEN实现动态交叉数据报表
C#.Net前台线与后台线区别
C#,Asp.Net线断点续传下载
框架能否支持同时访问数据源?
SQL使用LIKE查询模糊匹配特殊标点符号数据
Winform三层架构教,CS三层结构图源码实例讲解
C#.NET7 线播放mp3/wav音频|winmm.dll winapi播放音乐文件
C#操作Excel合并Excel文件
C# 使用设计模式构建通用数据库访问
使用观察者模式实时更新程序打开界面绑定组件数据
如何使用数据库IDatabase接口以及数据访问层应用

热门标签
.NET5 .NET6 .NET7 APP Auth-软件授权注册系统 Axios B/S B/S开发框架 Bug Bug记录 C#加密解密 C#源码 C/S CHATGPT CMS系统 CodeGenerator CSFramework.DB CSFramework.EF CSFrameworkV1学习版 CSFrameworkV2标准版 CSFrameworkV3高级版 CSFrameworkV4企业版 CSFrameworkV5旗舰版 CSFrameworkV6.0 DAL数据访问层 Database datalock DbFramework Demo教学 Demo下载 DevExpress教程 DOM EF框架 Element-UI EntityFramework ERP ES6 Excel FastReport GIT HR IDatabase IIS JavaScript LINQ MES MiniFramework MIS NavBarControl Node.JS NPM OMS ORM PaaS POS Promise API Redis SAP SEO SQL SQLConnector TMS系统 Token令牌 VS2022 VSCode VUE WCF WebApi WebApi NETCore WebApi框架 WEB开发框架 Windows服务 Winform 开发框架 Winform 开发平台 WinFramework Workflow工作流 Workflow流程引擎 版本区别 报表 踩坑日记 操作手册 代码生成器 迭代开发记录 基础资料窗体 架构设计 角色权限 开发sce 开发技巧 开发教程 开发框架 开发平台 开发指南 客户案例 快速搭站系统 快速开发平台 秘钥 密钥 权限设计 软件报价 软件测试报告 软件简介 软件开发框架 软件开发平台 软件开发文档 软件体系架构 软件下载 软著证书 三层架构 设计模式 生成代码 实用小技巧 收钱音箱 数据锁 数据同步 微信小程序 未解决问题 文档下载 喜鹊ERP 喜鹊软件 系统对接 详细设计说明书 行政区域数据库 需求分析 疑难杂症 蝇量级框架 蝇量框架 用户管理 用户开发手册 用户控件 在线支付 纸箱ERP 智能语音收款机 自定义窗体 自定义组件 自动升级程序