首页 > 代码库 > ACE线程管理

ACE线程管理

2024-07-10 14:01:37   223人阅读

头文件

#include "ace/Thread_Manager.h"   

等待所有线程的退出

ACE_Thread_Manager::instance()->wait();

此函数执行的时候会等待所有线程退出之后再退出，为什么要等待所有线程的退出呢？因为多线程环境下程序的执行步骤和单线程不同，多线程环境下如果不等待所有线程都退出就会导致某些线程执行了一部分就退出，因为CPU不会把时间都给这一个线程。

退出当前的线程

ACE_Thread_Manager::instance()->exit();

如果用函数创建线程，比如：

	ACE_Thread_Manager::instance()->spawn(  
		ACE_THR_FUNC(produce),   
		0,   
		THR_NEW_LWP | THR_DETACHED);

其中produce是一个函数：

void* produce(void*)
{
	int out = 1000;
	int in = 10;
	for (int i= 0;i<out;++i)
	{
		Eledata_Msg* msg = new Eledata_Msg;
		for (int j=0;j< in;j++)
		{
			//otl_datetime t(2014,4,24,2,4,4);
			otl_datetime t(2014,10,31,2,4,4);
			//msg->get_data().push_back(new e_eledata(j,t,t,2.2555,222.45,567.11,44,55,66,77,88,99,100,111,112,1000));
			msg->get_data().push_back(new e_eledata(j,t,t,2.2555,222.45,567.11,44,55,400,100,100,100,100,111,112,1000));
		}
		insert_eledata_to_db(msg);
	}
	cout<<"insert finished!"<<endl;
	ACE_Thread_Manager::instance()->exit();
	return 0;
}

这个函数可以被同时用来创建多个线程，比如：

	ACE_Thread_Manager::instance()->spawn(  
		ACE_THR_FUNC(produce),   
		0,   
		THR_NEW_LWP | THR_DETACHED); 
	ACE_Thread_Manager::instance()->spawn(  
		ACE_THR_FUNC(produce),   
		0,   
		THR_NEW_LWP | THR_DETACHED); 
	ACE_Thread_Manager::instance()->spawn(  
		ACE_THR_FUNC(produce),   
		0,   
		THR_NEW_LWP | THR_DETACHED);

如果每个线程做完自己的事情就要求退出，那最好在produce里写下线程退出的语句：

	cout<<"insert finished!"<<endl;
	ACE_Thread_Manager::instance()->exit();

这样程序执行的时候就会正常结束，而所有线程都结束的时候 ACE_Thread_Manager::instance()->wait();也就会结束了，从而main退出。

例如，输出如下：

sleep 5s begin
insert finished!
insert finished!
insert finished!
insert finished!
sleep 5s end
consumer exited
[root@localhost use_otl_test]# 

程序结束执行

更多详细内容，参考：http://blog.163.com/cp7618@yeah/blog/static/7023477720101024115547100/


联系
我们