现在的位置: 首页 > 综合 > 正文

boost库在工作(17)线程之二

2013年10月08日 ⁄ 综合 ⁄ 共 1156字 ⁄ 字号 评论关闭

前面的例子,还是过于简单,只能学会使用一个线程来调用一个函数来运行。接着下来,我们提高一点要求,使用两个或两个以上的线程来运行同一个函数。多个线程运行同一个函数,其实就是线程池的概念,因为一个线程只能在一个CPU在里运行,如果有四个CPU,那么最高效率就是有八个线程运行,一般来说是CPU的个数的两倍是最高效率的线程模型。因此,我们开发的软件会在不同的客户电脑上运行,不同的客户那里的电脑配置又不一样,这时就需要根据客户电脑的CPU个数来动态配置了。面对这样的需求,就需要使用boost库里的线程组来解决。在boost库里,封装的线程使用起来很方便,可以满足不同的需求。如下面的例子:

// boost_010.cpp : Defines the entry point for the console application.
//

#include "stdafx.h"
#include <boost/thread.hpp>
#include <boost/bind.hpp>
#include <boost/thread/mutex.hpp>

//线程组运行的函数
//软件开发人员: 蔡军生  2013-02-13
//QQ: 9073204
void Run(int nVal)
{
	//
	int nTemp = nVal * nVal;

	//下面输出需要加锁,不能多个线程共享输出。
	static boost::mutex mutexCout;
	boost::lock_guard<boost::mutex> autoLock(mutexCout);
	std::cout << "thread Run: [" << nVal << "] " << nTemp << std::endl;
}


int _tmain(int argc, _TCHAR* argv[])
{
	//定义一个线程组对象。
	boost::thread_group threadGroup;	

	//设置最大的线程个数。
	const int nMaxCount = 5;
	//循环地创建N个线程。
	for (int i = 0; i < nMaxCount; ++i)
	{
		threadGroup.create_thread(boost::bind(Run, i));
	}

	//等所有线程退出。
	threadGroup.join_all();

	system("PAUSE");

	return 0;
}

在这个例子里,主要使用了boost库里的线程池类thread_group,它提供了多个线程创建、保存、退出等管理。比如使用create_thread函数可以创建多个线程,每个线程都调用函数Run运行。使用join_all函数来确保所有线程运行,都从线程运行函数里退出来,如果其中一个线程没有办法退出,那么就会一直等待的。

可见,使用boost库里线程组很方面就解决多线程创建,运行等问题,对提高软件开发的效率是显而易见的。

抱歉!评论已关闭.