当前位置: 首页 > 编程日记 > 正文

C#多线程学习(四) 多线程的自动管理(线程池) (转载系列)——继续搜索引擎研究...

在多线程的程序中,经常会出现两种情况:

一种情况:   应用程序中,线程把大部分的时间花费在等待状态,等待某个事件发生,然后才能给予响应
                  这一般使用ThreadPool(线程池)来解决;

另一种情况:线程平时都处于休眠状态,只是周期性地被唤醒
                  这一般使用Timer(定时器)来解决;

ThreadPool类提供一个由系统维护的线程池(可以看作一个线程的容器),该容器需要 Windows 2000 以上系统支持,因为其中某些方法调用了只有高版本的Windows才有的API函数。

将线程安放在线程池里,需使用ThreadPool.QueueUserWorkItem()方法,该方法的原型如下:

//将一个线程放进线程池,该线程的Start()方法将调用WaitCallback代理对象代表的函数
public static bool QueueUserWorkItem(WaitCallback);

//重载的方法如下,参数object将传递给WaitCallback所代表的方法
public static bool QueueUserWorkItem(WaitCallback, object);

注意:
ThreadPool类是一个静态类,你不能也不必要生成它的对象。而且一旦使用该方法在线程池中添加了一个项目,那么该项目将是无法取消的。

在这里你无需自己建立线程,只需把你要做的工作写成函数,然后作为参数传递给ThreadPool.QueueUserWorkItem()方法就行了,传递的方法就是依靠WaitCallback代理对象,而线程的建立、管理、运行等工作都是由系统自动完成的,你无须考虑那些复杂的细节问题。

ThreadPool 的用法:
首先程序创建了一个ManualResetEvent对象,该对象就像一个信号灯,可以利用它的信号来通知其它线程。
本例中,当线程池中所有线程工作都完成以后,ManualResetEvent对象将被设置为有信号,从而通知主线程继续运行。

ManualResetEvent对象有几个重要的方法:
初始化该对象时,用户可以指定其默认的状态(有信号/无信号);
在初始化以后,该对象将保持原来的状态不变,直到它的Reset()或者Set()方法被调用:
Reset()方法:将其设置为无信号状态;
Set()方法:将其设置为有信号状态。
WaitOne()方法:使当前线程挂起,直到ManualResetEvent对象处于有信号状态,此时该线程将被激活。然后,程序将向线程池中添加工作项,这些以函数形式提供的工作项被系统用来初始化自动建立的线程。当所有的线程都运行完了以后,ManualResetEvent.Set()方法被调用,因为调用了ManualResetEvent.WaitOne()方法而处在等待状态的主线程将接收到这个信号,于是它接着往下执行,完成后边的工作。

ThreadPool 的用法示例:

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

namespace ThreadExample
{
    
//这是用来保存信息的数据结构,将作为参数被传递
    public class SomeState
    {
      
public int Cookie;
      
public SomeState(int iCookie)
      {
        Cookie 
= iCookie;
      }
    }

    
public class Alpha
    {
  
public Hashtable HashCount;
  
public ManualResetEvent eventX;
  
public static int iCount = 0;
  
public static int iMaxCount = 0;
  
        
public Alpha(int MaxCount) 
  {
         HashCount 
= new Hashtable(MaxCount);
         iMaxCount 
= MaxCount;
  }

  
//线程池里的线程将调用Beta()方法
  public void Beta(Object state)
  {
      
//输出当前线程的hash编码值和Cookie的值
         Console.WriteLine(" {0} {1} :", Thread.CurrentThread.GetHashCode(),((SomeState)state).Cookie);
      Console.WriteLine(
"HashCount.Count=={0}, Thread.CurrentThread.GetHashCode()=={1}", HashCount.Count, Thread.CurrentThread.GetHashCode());
      
lock (HashCount) 
      {
        
//如果当前的Hash表中没有当前线程的Hash值,则添加之
        if (!HashCount.ContainsKey(Thread.CurrentThread.GetHashCode()))
             HashCount.Add (Thread.CurrentThread.GetHashCode(), 
0);
         HashCount[Thread.CurrentThread.GetHashCode()] 
= 
            ((
int)HashCount[Thread.CurrentThread.GetHashCode()])+1;
      }
          
int iX = 2000;
          Thread.Sleep(iX);
          
//Interlocked.Increment()操作是一个原子操作,具体请看下面说明
          Interlocked.Increment(ref iCount);

          
if (iCount == iMaxCount)
          {
          Console.WriteLine();
        Console.WriteLine(
"Setting eventX ");
        eventX.Set();
        }
    }
  }

        
public class SimplePool
        {
            
public static int Main(string[] args)
            {
                Console.WriteLine(
"Thread Pool Sample:");
                
bool W2K = false;
                
int MaxCount = 10;//允许线程池中运行最多10个线程
                
//新建ManualResetEvent对象并且初始化为无信号状态
                ManualResetEvent eventX = new ManualResetEvent(false);
                Console.WriteLine(
"Queuing {0} items to Thread Pool", MaxCount);
                Alpha oAlpha 
= new Alpha(MaxCount); 
                
//创建工作项
                
//注意初始化oAlpha对象的eventX属性
                oAlpha.eventX = eventX;
                Console.WriteLine(
"Queue to Thread Pool 0");
                
try
                {
                    
//将工作项装入线程池 
                    
//这里要用到Windows 2000以上版本才有的API,所以可能出现NotSupportException异常
                    ThreadPool.QueueUserWorkItem(new WaitCallback(oAlpha.Beta), new SomeState(0));
                    W2K 
= true;
                }
                
catch (NotSupportedException)
                {
                    Console.WriteLine(
"These API's may fail when called on a non-Windows 2000 system.");
                    W2K 
= false;
                }
                
if (W2K)//如果当前系统支持ThreadPool的方法.
                {
                    
for (int iItem=1;iItem < MaxCount;iItem++)
                    {
                        
//插入队列元素
                        Console.WriteLine("Queue to Thread Pool {0}", iItem);
                        ThreadPool.QueueUserWorkItem(
new WaitCallback(oAlpha.Beta), new SomeState(iItem));
                    }
                    Console.WriteLine(
"Waiting for Thread Pool to drain");
                    
//等待事件的完成,即线程调用ManualResetEvent.Set()方法
                    eventX.WaitOne(Timeout.Infinite,true);
                    
//WaitOne()方法使调用它的线程等待直到eventX.Set()方法被调用
                    Console.WriteLine("Thread Pool has been drained (Event fired)");
                    Console.WriteLine();
                    Console.WriteLine(
"Load across threads");
                    
foreach(object o in oAlpha.HashCount.Keys)
                        Console.WriteLine(
"{0} {1}", o, oAlpha.HashCount[o]);
                }
                Console.ReadLine();
                
return 0;
            }
        }
    }

}

程序中应该引起注意的地方:
SomeState类是一个保存信息的数据结构,它在程序中作为参数被传递给每一个线程,因为你需要把一些有用的信息封装起来提供给线程,而这种方式是非常有效的。
程序出现的InterLocked类也是专为多线程程序而存在的,它提供了一些有用的原子操作。

原子操作:就是在多线程程序中,如果这个线程调用这个操作修改一个变量,那么其他线程就不能修改这个变量了,这跟lock关键字在本质上是一样的。

ContractedBlock.gifExpandedBlockStart.gif程序的输出结果:
Thread Pool Sample:
Queuing 
10 items to Thread Pool
Queue to Thread Pool 
0
Queue to Thread Pool 
1
Queue to Thread Pool 
2
Queue to Thread Pool 
3
Queue to Thread Pool 
4
Queue to Thread Pool 
5
 
2 0 :
HashCount.Count
==0, Thread.CurrentThread.GetHashCode()==2
Queue to Thread Pool 
6
Queue to Thread Pool 
7
Queue to Thread Pool 
8
Queue to Thread Pool 
9
Waiting 
for Thread Pool to drain
 
4 1 :
HashCount.Count
==1, Thread.CurrentThread.GetHashCode()==4
 
6 2 :
HashCount.Count
==1, Thread.CurrentThread.GetHashCode()==6
 
7 3 :
HashCount.Count
==1, Thread.CurrentThread.GetHashCode()==7
 
2 4 :
HashCount.Count
==1, Thread.CurrentThread.GetHashCode()==2
 
8 5 :
HashCount.Count
==2, Thread.CurrentThread.GetHashCode()==8
 
9 6 :
HashCount.Count
==2, Thread.CurrentThread.GetHashCode()==9
 
10 7 :
HashCount.Count
==2, Thread.CurrentThread.GetHashCode()==10
 
11 8 :
HashCount.Count
==2, Thread.CurrentThread.GetHashCode()==11
 
4 9 :
HashCount.Count
==2, Thread.CurrentThread.GetHashCode()==4

Setting eventX
Thread Pool has been drained (Event fired)

Load across threads
11 1
10 1
9 1
8 1
7 1
6 1
4 2
2 2

我们应该彻底地分析上面的程序,把握住线程池的本质,理解它存在的意义是什么,这样才能得心应手地使用它。

C#多线程学习 系列教程(强烈推荐)

§1. C#多线程学习(一) 多线程的相关概念(转载系列)——继续搜索引擎研究

http://www.cnblogs.com/OceanChen/archive/2009/02/02/1382233.html

§2. C#多线程学习(二) 如何操纵一个线程 (转载系列)——继续搜索引擎研究

http://www.cnblogs.com/OceanChen/archive/2009/02/02/1382232.html

§3. C#多线程学习(三) 生产者和消费者 (转载系列)——继续搜索引擎研究

http://www.cnblogs.com/OceanChen/archive/2009/02/02/1382231.html

§4. C#多线程学习(四) 多线程的自动管理(线程池) (转载系列)——继续搜索引擎研究

http://www.cnblogs.com/OceanChen/archive/2009/02/02/1382230.html

§5. C#多线程学习(五) 多线程的自动管理(定时器) (转载系列)——继续搜索引擎研究

http://www.cnblogs.com/OceanChen/archive/2009/02/02/1382229.html

§6. C#多线程学习(六) 互斥对象(转载系列)——继续搜索引擎研究

http://www.cnblogs.com/OceanChen/archive/2009/02/02/1382227.html

文章出处:http://www.cnblogs.com/xugang/archive/2008/04/06/1138856.html

转载于:https://www.cnblogs.com/OceanChen/archive/2009/02/02/1382230.html

相关文章:

使用Node.js快速搭建WebSocket server

原文地址&#xff1a;http://my.oschina.net/yushulx/blog/309413 目录[-] 安装服务端客户端参考安装 ?1npm install ws服务端 server.js ?12345678var WebSocketServer require(ws).Server, wss new WebSocketServer({port: 8080});wss.on(connection, function(ws) {ws.o…

android采用MVP完整漫画APP、钉钉地图效果、功能完善的音乐播放器、仿QQ动态登录效果、触手app主页等源码...

Android精选源码 一个可以上拉下滑的Ui效果&#xff0c;觉得好看可以学学 APP登陆页面适配 一款采用MVP的的完整漫画APP源码 android实现钉钉地图效果源码 一个使用单个文字生成壁纸图片的app android 仿QQ动态背景登录效果源码 功能完善的Android 手机本地音乐文件播放器 andr…

1035 Password

很适合用结构体数组的一道题 #include<cstdio> #include<cmath> #include<cstring> #include<algorithm> using namespace std;struct info{char usr[11]"";char pwd[11]"";bool changed false; }infos[1010];int main(){int n,…

Android -- DrawerLayout

抽屉效果的导航菜单 喜欢知乎的都应该装的用知乎日报吧~这里指Android的不是IOS的。知乎日报的导航菜单就是用DrawerLayout实现的。 觉得这种侧滑的抽屉效果的菜单很好。 不用切换到另一个页面&#xff0c…

Socketserver 笔记

引入Socketserver的背景&#xff1a;我们之前使用socket编程的时候&#xff0c;Server端创建一个连接循环&#xff08;建立连接&#xff09;一个通信循环&#xff08;基于一次连接建立通信循环&#xff09;&#xff0c;&#xff08;这里的黏包问题我们的实现方式是&#xff1a;…

Delphi 调用C#编写的WebService 参数为Null解决方法

今天测试.net 2.0的WebService&#xff0c;发现了一个大问题。就是无法获取参数&#xff0c;参数永远是null。当然了使用.net调用 没有任何问题&#xff0c;web测试页也正常。不论是Delphi7还是java调用的结果的都是一样的&#xff0c;难道是.net 2.0的Bug&#xff1f; 测试结…

1025 PAT Ranking

1. 考生的编号是数字字符串&#xff0c;但是没必要转化成整数再比较&#xff0c;可以直接用strcmp() 2. 对整体的排名进行编号时所有信息都已经齐备&#xff0c;可以边编号边输出 3. 需要有些思量的地方是部分编号&#xff0c;当当前学生的分数不等于他上一个该怎么办 4. 真…

C#编写的多生产者多消费者同步问题

// 多个生产者和多个消费者&#xff0c;能生产n个产品的情况using System; using System.Threading;public class HoldIntegerSynchronized{private int[] buffer; //缓冲区private int occupiedBufferCount 0;private int readPosition 0 , writePosition 0;//下一个读到的…

展望2009,回眸2008

2008年真正的过去了&#xff0c;已经感觉不到2008年的存在。 2009年来了&#xff0c;似乎真正的来了。 生活的压力更大了&#xff0c;工作也不太顺利。 希望越来越好&#xff0c;也不知道是不是真的该跳槽了。 待在这里很郁闷。 转载于:https://www.cnblogs.com/tacker/archive…

m_Orchestrate learning system---七、如何快速学好前端

m_Orchestrate learning system---七、如何快速学好前端 一、总结 一句话总结&#xff1a;看视频啊&#xff0c;系统看视频啊 1、如何解决单词数字太长超出边界的问题&#xff1f; word-wrap 把编辑删除都挤跑了 2、amaze ui中a标签和button标签可以互换么&#xff1f; 其实弄上…

1062 Talent and Virtue

1.在结构体里面设置total_grades属性是明智之举&#xff0c;但是不可以在结构体内得到total_gradesvirtue_gradetalent_grade; 2.弄清题意&#xff0c;对人进行分类&#xff0c;等级越高type值越小&#xff0c;但是注意分的类别也许出现交叉的情况&#xff0c;细的要出现在粗的…

用百度直达号获取新用户 让顾客直达商家服务

直达号是什么? 直达号&#xff0c;商家在百度移动平台的官方服务账号。基于移动搜索、账号、地图、个性化推荐等多种方式&#xff0c;让顾客随时随地直达商家服务。 直达号其实就是两个功能&#xff1a;  √ 提供一个手机网站模板&#xff0c;入住商家可以建自己的手机网站。…

【Quartz】实现接口封装化(二)

原文:【Quartz】实现接口封装化&#xff08;二&#xff09;前言 通过昨天的努力终于算是了解Quartz这个定时器的简单使用&#xff0c;为了更深一步的了解和基于以后希望在项目中能使用他。所有我对他做了一下简单的封装操作&#xff0c;便于以后从新建立新工作和触发器&#…

怎么成为优秀的软件模型设计者?

作者&#xff1a;Scott Ambler著&#xff0c;乐林峰 译 本文选自&#xff1a;www.umlchina.com 2002年03月25日 我们期待自己成为一个优秀的软件模型设计者&#xff0c;但是&#xff0c;要怎样做&#xff0c;又从哪里开始呢&#xff1f; 将下列原则应用到你的软件工程中&…

1012 The Best Rank

思路&#xff1a;读入全部的数据之后&#xff0c;按照四个cmp函数对数组进行排序&#xff0c;给每生的4个科目的排名赋值&#xff0c;读入要检验的id后使用strcmp对数组中的id进行遍历(幸好这里数组大小和要检验的数目乘积不超过4万)&#xff0c;如果找到了相同id,调用写好的得…

SDWebImage使用——一个可管理远程图片加载的类库

SDWebImage托管在github上。https://github.com/rs/SDWebImage 这个类库提供一个UIImageView类别以支持加载来自网络的远程图片。具有缓存管理、异步下载、同一个URL下载次数控制和优化等特征。 将SDWebImage类库添加入工程时&#xff0c;一定注意需要添加MapKit.framework&…

EXECL使用技巧(转)

2007-03-18 09:07 一、求字符串中某字符出现的次数&#xff1a; 例&#xff1a;求A1单元格中字符"a"出现的次数&#xff1a; LEN(A1)-LEN(SUBSTITUTE(A1,"a","")) 二、如何在不同工作薄之间复制宏&#xff1a; 1、打开含有宏的工作薄&#xff0c…

微信小程序(canvas)画图保存到本地相册(wepy)

html标签部分 因为这个需要用户授权 所以需要使用button&#xff0c;画布使用的是canvas&#xff0c;这个可以参考小程序官方文档&#xff0c;代码如下 <button classbtn type"default" open-type"getUserInfo" tapexportImg>生成图片保存到本地&l…

1016 Phone Bills

目录 概述&#xff1a; 一些小的注意点 AC代码 概述&#xff1a; 这道题是我迄今做出来的最复杂的一道PAT了&#xff0c;该题被归类到排序专题下&#xff0c;其实还涉及到大量的字符串处理等别的我暂时也说不出的知识点。 排序函数我写了两个&#xff0c;1是cmp&#xff0…

C# GDI+ 简单绘图 (三) 仿浏览器截屏效果

感谢大家的支持,这几天从早忙到晚,一个字累呀!!!现在挺困的,但是又不习惯这么早睡觉,哎~~还是利用这个时间继续来写第三篇吧.  前两篇已经基本向大家介绍了绘图的基本知识.那么,我就用我们上两篇所学的,做几个例子&#xff0e;  我们先来做一个简单的----仿QQ截图,关于这个…

POJ 1236 Network of Schools(tarjan)

Network of SchoolsDescription A number of schools are connected to a computer network. Agreements have been developed among those schools: each school maintains a list of schools to which it distributes software (the “receiving schools”). Note that if B …

如何设置网页自动刷新(JSP,JS,HTML)

http://blog.163.com/ylx282006126/blog/static/59772717201111685917664/ 转载于:https://www.cnblogs.com/liuzhuqing/p/7480284.html

1084 Broken Keyboard

两个注意的点 1.本题被归到散列专题下&#xff0c;但是由于是逐字符地映射到整形&#xff0c;可以直接把布尔型哈希数组的大小设置为ASCII的数量128&#xff0c;然后直接将字符作为数组下标(如果是字符串&#xff0c;才需要自己写一个哈希函数&#xff0c;将字符串映射到整形&…

Android提示框与通知的使用

1.通知 Android 3.0以前使用的方法 1 NotificationManager nm (NotificationManager) getSystemService(NOTIFICATION_SERVICE); 2 Notification notification new Notification(R.drawable.dss, 3 "通知到了", Syste…

nginx安全日志分析脚本的编写

https://blog.csdn.net/nextdoor6/article/details/51914966

[转]笑死人的考试填空

高考完后又是中考&#xff0c;考题千奇百怪&#xff0c;答卷也五花八门。真佩服现在的学生啊&#xff0c;思维跳脱&#xff0c;天马行空&#xff0c;和我们那时候的循规蹈矩&#xff0c;差别太大了&#xff0c;呵呵。看一组语文试卷中的填空题&#xff1a;1.__________&#xf…

1033 旧键盘打字

1. 非常奇怪&#xff0c;明明都说了用下划线替代空格&#xff0c;但是用scanf读入的时候就会有1个测试点没通过&#xff0c;换成cin.getline就通过了 2.3种情况下对应的哈希表赋值为true。1是上来就赋值&#xff0c;2是对于大写字母把对应小写字母也赋值&#xff0c;这里注意直…

OLE 操作Excel 详解(转)

使用Excel模板进行报表的开发. 今年搞的Excel比较多&#xff0c;总结了一下&#xff0c;相信常用的操作包含的差不多了。 可以首先定义一个无内容的Excel报表模板文件. 通过Tcode SMW0 上传至SAP数据库中备用.(注: Web对象应该选择’WebRFC 应用程序的二进制数据’) 开发程序…

只需3分钟,就能轻松创建 一个SpreadJS的React项目

概述SpreadJS 纯前端表格控件 V11.2(SP2) 已经全面支持了 React 的拓展。接下来我们看下如何利用3分钟快速创建一个 SpreadJS 的 React 项目。1.新建React 项目&#xff08;耗时 1 Min&#xff09;直接运行&#xff1a;npx create-react-app react-spread-sheets还不清楚什么是…

1039 到底买不买

很典型的散列题&#xff0c;对于shop和eva有的珠子(即字符)&#xff0c;各开一个128长度的整形散列表计数&#xff0c;将字符作为下标读入。 然后从0~127进行遍历&#xff0c;看每个下标下两个散列表的数量&#xff0c;如果有shop<eva说明不买&#xff0c;但是遍历仍然要继…