没有合适的资源?快使用搜索试试~ 我知道了~
资源推荐
资源详情
资源评论
C#实现控制线程池最大数并发线程实现控制线程池最大数并发线程
主要介绍了C#实现控制线程池最大数并发线程的相关资料,需要的朋友可以参考下
1. 实验目的:实验目的:
使用线程池的时候,有时候需要考虑服务器的最大线程数目和程序最快执行所有业务逻辑的取舍。
并非逻辑线程越多也好,而且新的逻辑线程必须会在线程池的等待队列中等待 ,直到线程池中工作的线程执行完毕,
才会有系统线程取出等待队列中的逻辑线程,进行CPU运算。
2. 解决问题:解决问题:
<a>如果不考虑服务器实际可支持的最大并行线程个数,程序不停往线程池申请新的逻辑线程,这个时候我们可以发现CPU
的使用率会不断飙升,并且内存、网络带宽占用也会随着逻辑线程在CPU队列中堆积,而不断增大。
如果我们想在主程序有200个http网络通讯需要执行,如何每次循环用10个线程并发处理10个网络http通讯回话,下一次循
环只有在上一次循环的10个线程都执行完毕后才会执行下一次循环,并且主程序监听和等待200个http网络通讯都在CPU线程
池中执行完毕后,才会退出主程序。
3. 实现逻辑:
我们通过两个AutoResetEvent和线程监听器Monitor,分别实现:
<a>wait_sync: 任务线程的 并发执行,每次循环只处理最大10个线程分别对网络做http通讯回话。并且当前循环的10个线
程都执行完毕后,才会进行下一次循环处理。
wait_main: 主程序线程的监听和等待,只有所有任务线程都执行完毕后,主程序线程才会退出程序。
<c> list_Thread: 负责记录每次循环,CPU实际分配的系统线程的个数。和Monitor配合使用,Monitor.Enter(list_Thread)=
占用共享线程资源的占用锁,Monitor.Exit(list_Thread)释放共享线程资源的占用锁。
<d> n_total_thread: 配合wait_main使用,记录全部逻辑线程,已经执行完毕的当前总个数,用来判断主线程是否还需要继
续等待,还是可以结束主程序运行。
4. 主要代码:
<a> 线程池控制代码,如下:
/// <summary>
/// 多线程调用WCF
/// </summary>
/// <param name="select">调用WCF的方式,1=Restful,2=Tcp</param>
/// <param name="num"></param>
static void DoTest_MultiThread(string select, long num)
{
int n_max_thread = 10; // 设置并行最大为10个线程
int n_total_thread = 0; // 用来控制:主程序的结束执行,当所有任务线程执行完毕
ILog log_add = new LogHelper("Add_Thread");
ILog log_del = new LogHelper("Del_Thread");
ILog log_wait = new LogHelper("Wait_Thread");
ILog log_set = new LogHelper("Set_Thread");
ILog log_for = new LogHelper("For_Thread");
Console.Title = string.Format("调用WCF的方式 => {0}, 调用次数=> {1}"
, select == "1" ? "Restful" : "Socket"
, num);
List<int> list_Thread = new List<int>();
System.Threading.AutoResetEvent wait_sync = new System.Threading.AutoResetEvent(false); // 用来控制:并发最大个数线程=n_max_thread
System.Threading.AutoResetEvent wait_main = new System.Threading.AutoResetEvent(false); // 用来控制:主程序的结束执行,当所有任务线程执行完毕
DateTime date_step = DateTime.Now;
for (long i = 0; i < num; i++)
{
Num_Query_Static++;
if (i >0 && (i+1-1) % n_max_thread == 0) // -1 表示第max个线程尚未开始
{
//log_wait.Info(string.Format("thread n= {0},for i= {1}", dic_Thread.Count, i + 1));
wait_sync.WaitOne(); // 每次并发10个线程,等待处理完毕后,在发送下一次并发线程
}
log_for.Info(string.Format("thread n= {0},for i= {1}", list_Thread.Count, i + 1));
System.Threading.ThreadPool.QueueUserWorkItem
((data) =>
{
int id = System.Threading.Thread.CurrentThread.ManagedThreadId;
System.Threading.Monitor.Enter(list_Thread);
资源评论
- billravi2023-06-02资源内容详实,描述详尽,解决了我的问题,受益匪浅,学到了。
weixin_38729108
- 粉丝: 5
- 资源: 896
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
最新资源
- 基于keras+fasterRCNN,在VOC格式的口罩数据集上训练,检测人群中有无戴口罩python源码+模型
- 基于opencv+qt5机器视觉的传统缺陷检测, 即采用标准图片和待测图片进行pixel to pixel的XOR操作源码+文档
- 管道内检测缺陷数据库管理系统源码+文档说明+sln
- 毕业设计-低功耗STM32F411开发板(原理图+PCB源文件+官方例程+驱动等)源码+文档说明+截图
- 基于yolov5-tensorRT检测+发动机缸体内壁缺陷检测系统源码+文档说明
- 基于C++实现的锂电池缺陷检测源码+文档说明
- push_version
- 软件自制图像批量压缩工具
- 经典缺陷检测算法源码整理包含PaDiM(2020ICPR)、PatchCore(2022CVPR)、SimpleNet+文档说明
- 基于深度学习的抗梯度噪声的缺陷检测器python源码+文档说明+模型的预训练
资源上传下载、课程学习等过程中有任何疑问或建议,欢迎提出宝贵意见哦~我们会及时处理!
点击此处反馈
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功