boost实现的任务队列模板代码,C代码库,德仔网

代码语言

代码分类

【C】 boost实现的任务队列模板

作者:Dezai.CN / 发布于2013/7/13/ 712


	/*
	*
	* Copyright (C) 2009 jack.wgm, microcai.
	* For conditions of distribution and use, see copyright notice
	* in (http://code.google.com/p/netsever/source/browse/trunk/COPYING)
	*
	* Author: jack.wgm
	* Email: jack.wgm@gmail.com
	*/

	#ifndef JOBQUEUE_H__
	#define JOBQUEUE_H__

	#if defined(_MSC_VER) && (_MSC_VER >= 1200)
	# pragma once
	#endif // defined(_MSC_VER) && (_MSC_VER >= 1200)

	namespace net
	{

	 template <typename Job>
	 class jobqueue
	 {
	 public:
	 jobqueue(void);
	 virtual ~jobqueue(void);

	 void submitjob(const Job& x);
	 Job getjob();
	 void notify_all();

	 private:
	 bool exitwait_;
	 std::list<Job> list_;
	 boost::mutex mutex_;
	 boost::condition worktobedone_;
	 };

	 template <typename Job>
	 jobqueue<Job>::jobqueue(void)
	 : exitwait_(false)
	 {}

	 template <typename Job>
	 jobqueue<Job>::~jobqueue(void)
	 {}

	 template <typename Job>
	 void jobqueue<Job>::submitjob(const Job& x)
	 {
	 boost::mutex::scoped_lock lock(mutex_);
	 list_.push_back(x);
	 worktobedone_.notify_all();
	 }

	 template <typename Job>
	 void jobqueue<Job>::notify_all()
	 {
	 exitwait_ = true;
	 worktobedone_.notify_all();
	 }

	 template <typename Job>
	 Job jobqueue<Job>::getjob()
	 {
	 boost::mutex::scoped_lock lock(mutex_);
	 while (list_.size()==0 && !exitwait_)
	 worktobedone_.wait(lock);
	 Job tmp;
	 if (exitwait_)
	 return tmp;
	 tmp = list_.front();
	 list_.pop_front();
	 return tmp;
	 }

	} // namespace net

	#endif // JOBQUEUE_H__

评论列表

本站所提供的代码，版权归原作者所有，若有侵犯作者版权，请与我们联系，我们将立即删除或修改。谢谢!
本站所有代码发布及提供者。

试试其它关键字

　任务队列　

同语言下

可能有用的

Dezai.CN贡献的其它代码(4037)