C#多线程实现方法——线程池(Thread Pool)
ThreadPool使用
需要定义waitcallback委托形式如
- public delegate void WaitCallback(object state);
public delegate void WaitCallback(object state);
例如如下例子:
- static private void ThreadWorker(object state)
- {
- int num = (int)state;
- if (num > 0)
- {
- for (int i = 0; i < 3; i++)
- {
- Thread.Sleep(1000);// sleep for one second
- num++;
- Console.WriteLine(string.Format("Current thread {0} deal with {1}.", Thread.CurrentThread.ManagedThreadId, num));
- }
- }
- return;
- }
static private void ThreadWorker(object state)
{
int num = (int)state;
if (num > 0)
{
for (int i = 0; i < 3; i++)
{
Thread.Sleep(1000);// sleep for one second
num++;
Console.WriteLine(string.Format("Current thread {0} deal with {1}.", Thread.CurrentThread.ManagedThreadId, num));
}
}
return;
}
就是一个简单的隔一秒增加一的自增器。
调用ThreadPool的方法很简单,需要引用System.Threading。接着使用QueueUserWorkItem或者UnsafeQueueUserWorkerItem。
- public static class Th read Pool {
- }
- public static bool QueueUserWorkltem (WaitCa llback ca llBack) ;
- public stat ic bool QueueUserWork ltem (
- WaitCallback callBack,
- object state
- ) ;
- [Secu rityPermi ssion (Secu rityAction .Lin kDemand, Flags=
- Secu rityPermi ssionFlag . ControlPol icy l
- Secu rityPermi ssionF lag . Cont rolEvidence )]
- public stat ic bool UnsafeQueueUserWorkltem (
- WaitCallback callBac k,
- obj ect state
- ) ;
public static class Th read Pool {
}
public static bool QueueUserWorkltem (WaitCa llback ca llBack) ;
public stat ic bool QueueUserWork ltem (
WaitCallback callBack,
object state
) ;
[Secu rityPermi ssion (Secu rityAction .Lin kDemand, Flags=
Secu rityPermi ssionFlag . ControlPol icy l
Secu rityPermi ssionF lag . Cont rolEvidence )]
public stat ic bool UnsafeQueueUserWorkltem (
WaitCallback callBac k,
obj ect state
) ;
可以接受一个参数传递给异步线程。
结合前面的自增器,下面例子是申请5个异步线程来运行上述的自增器,传递的值是10,20,30,40,50。接着等待足够长的时间来等待所有线程池里的工作完成。
- for (int i = 1; i <= 5; i++)
- ThreadPool.QueueUserWorkItem(ThreadWorker, i * 10);
- for (int i = 0; i < 5; i++)
- Thread.Sleep(1000);// wait for all threads finish
for (int i = 1; i <= 5; i++)
ThreadPool.QueueUserWorkItem(ThreadWorker, i * 10);
for (int i = 0; i < 5; i++)
Thread.Sleep(1000);// wait for all threads finish
从上面可以看到线程池的使用非常的简单,只需要提供符合waitcallback的委托的工作函数,接着调用QueueUserWorkItem或者UnsafeQueueUserWorkItem添加到线程池里就ok了。但是线程池的缺点也是有的,首先,没有简单的方法来知道工作线程已经完成了,不想asynchronous中提供那么多种等待异步结束的方法,更谈不上能够添加回调函数,也不想thread那样可以使用join函数来等待线程或者使用abort函数中断正在运行的工作项。同时由于它是后台线程,也就是意味如果没有前台线程,程序就关闭,所有正在运行的或者还留在线程池里的工作项就给强制中断。所以不能将一些类似保存退出的操作放进线程池里,因为没有保证机制能够证明所有的线程池里正在运行或者还没运行的工作项能够具有明确的行为。
同步机制
ThreadPool没有提供简单的方法来获取工作线程已经结束,所以需要通过事件或者其他的内核对象来实现同步机制。
1. 如果需要获取某一个工作线程是否结束可以使用手动事件来实现。
- static private ManualResetEvent finish = new ManualResetEvent(false);
- static private void ThreadWorker(object state)
- {
- {
- for (int i = 0; i < 5; i++)
- {
- Thread.Sleep(1000);
- Console.WriteLine("current thead {0} wait for {1} seconds.", Thread.CurrentThread.ManagedThreadId, i + 1);
- }
- finish.Set();
- }
- return;
- }
static private ManualResetEvent finish = new ManualResetEvent(false);
static private void ThreadWorker(object state)
{ {
for (int i = 0; i < 5; i++)
{
Thread.Sleep(1000);
Console.WriteLine("current thead {0} wait for {1} seconds.", Thread.CurrentThread.ManagedThreadId, i + 1);
}
finish.Set();
}
return;
}
主调函数实现代码为:
- ThreadPool.QueueUserWorkItem(ThreadWorker);
- finish.WaitOne();
- finish.Close();
ThreadPool.QueueUserWorkItem(ThreadWorker);
finish.WaitOne();
finish.Close();
或者使用匿名委托函数加using关键字保证了事件的释放
- using (ManualResetEvent finish = new ManualResetEvent(false))
- {
- ThreadPool.QueueUserWorkItem(delegate {
- for (int i = 0; i < 5; i++)
- {
- Thread.Sleep(1000);
- Console.WriteLine("current thead {0} wait for {1} seconds.", Thread.CurrentThread.ManagedThreadId, i + 1);
- }
- finish.Set();
- });
- finish.WaitOne();
- }
using (ManualResetEvent finish = new ManualResetEvent(false))
{
ThreadPool.QueueUserWorkItem(delegate {
for (int i = 0; i < 5; i++)
{
Thread.Sleep(1000);
Console.WriteLine("current thead {0} wait for {1} seconds.", Thread.CurrentThread.ManagedThreadId, i + 1);
}
finish.Set();
});
finish.WaitOne();
}
2.如果需要获取多个工作线程是否结束可以通过最后一个工作线程来触发事件来实现。
如果使用前面的方法给每一个工作线程分配一个事件,然后等待所有事件给触发,是非常低效的,可以使用如下方法
- using (ManualResetEvent finish = new ManualResetEvent(false))
- {
- int nTask = 10;
- for (int i = 0; i < nTask; i++)
- {
- ThreadPool.QueueUserWorkItem(delegate
- {
- for (int j = 0; j < 3; j++)
- {
- Thread.Sleep(1000);
- Console.WriteLine("current thead {0} wait for {1} seconds.", Thread.CurrentThread.ManagedThreadId, i * 10 + j + 1);
- }
- if (Interlocked.Decrement(ref nTask) == 0)
- {
- finish.Set();
- }
- }, i);
- }
- finish.WaitOne();
- }
using (ManualResetEvent finish = new ManualResetEvent(false))
{
int nTask = 10;
for (int i = 0; i < nTask; i++)
{
ThreadPool.QueueUserWorkItem(delegate
{
for (int j = 0; j < 3; j++)
{
Thread.Sleep(1000);
Console.WriteLine("current thead {0} wait for {1} seconds.", Thread.CurrentThread.ManagedThreadId, i * 10 + j + 1);
}
if (Interlocked.Decrement(ref nTask) == 0)
{
finish.Set();
}
}, i);
}
finish.WaitOne();
}
不过注意由于使用过了匿名委托所以i的值是不确定,有可能是1或者是10,所以为了改变这种情况不能使用匿名委托,
- static private int _num = 10;
- static private ManualResetEvent finish = new ManualResetEvent(false);
- static private void ThreadWork(object state)
- {
- int i = (int)state;
- for (int j = 0; j < 3; j++)
- {
- Thread.Sleep(1000);
- Console.WriteLine("current thead {0} wait for {1} seconds.", Thread.CurrentThread.ManagedThreadId, i * 10 + j + 1);
- }
- if (Interlocked.Decrement(ref _num) == 0)
- finish.Set();
- }
static private int _num = 10;
static private ManualResetEvent finish = new ManualResetEvent(false);
static private void ThreadWork(object state)
{
int i = (int)state;
for (int j = 0; j < 3; j++)
{
Thread.Sleep(1000);
Console.WriteLine("current thead {0} wait for {1} seconds.", Thread.CurrentThread.ManagedThreadId, i * 10 + j + 1);
}
if (Interlocked.Decrement(ref _num) == 0)
finish.Set();
}
主调函数实现代码为:
- for (int i = 0; i < _num; i++)
- {
- ThreadPool.QueueUserWorkItem(ThreadWork, i);
- }
- finish.WaitOne();
- finish.Close();
最新文章
- [转]VS 2013 连接数据库报错 未能加载文件或程序集 Microsoft.SqlServer.Management.Sdk.Sfc
- uiwebview 兼容性 - IOS8及以上 WKWebView
- linux下IPTABLES配置详解
- UI进阶 地图
- RESTful HTTP实践
- SQLServer 2008数据库查看死锁、堵塞的SQL语句
- EditText操作收集
- ThinkPHP第十天(_initialize方法,SESSION销毁,分组配置,include文件引入,JOIN用法)
- linux开机启动服务和chkconfig使用方法(转)
- Block学习一门:基本使用,使用block包NSURLRequest异步请求
- node.js与比特币(typescript实现)
- 将Myeclipse项目改成Eclipse项目
- Exception in thread ";main"; java.lang.NoSuchMethodError: scala.Predef$.refArrayOps([Ljava/lang/Object;)Lscala/collection/mutable/ArrayOps;
- Django 命令行工具django-admin.py与manage.py
- jq的innerWidth()遇到的坑
- pandas:对字符串类型做差分比较
- C语言学习常见错误分析
- SXH232摄像头使用示范
- unity平行光太亮?物体发白?可能你使用了2个或多个平行光
- PHP导出Excel,设置表格样式,填充颜色等较为复杂样式