多线程定时调度模块设计

         前段时间由于用C++语言开发后台行情系统，涉及到一些多线程的封装和任务调度，思前想后，觉得抽象一套比较通用的任务调度框架，将之编译成一个独立的So,可以大大简

化后续的多线程，以及定时调度规则。

      大体的接口可以划分为三个接口：

Operation.hpp，该类为用户需要实现的虚接口，用户即调度任务，用户派生即可

代码：

#pragma once
//#ifndef _OPERATION_UTILS_HPP_
//#define _OPERATION_UTILS_HPP_
//#include "COperationFacade.hpp"
//#include <boost/shared_ptr.hpp>
#include "export.h"


namespace TaskUtils {

class  TASKUTILT_API COperation //: public COperationFacade
{
public:
virtual ~COperation() throw(){}
/*
函数功能：任务执行的纯虚接口，子类实现
返回：执行任务的结果
*/
virtual bool Run() = 0;
};
}

  ThreadPoolUtils.hpp 线程池封装接口

#pragma once
#include <boost/shared_ptr.hpp>
#include "Operation.hpp"
//#include "ThreadComDef.hpp"
#include "export.h"
#include "OperationHandler.hpp"


namespace TaskUtils {




//typedef boost::shared_ptr<COperation> COperationPtr;


class TASKUTILT_API CThreadPoolUtils
{
public:
virtual ~CThreadPoolUtils() throw(){}
/*
函数功能：插入一个执行任务
入参：（1）data 的执行指针
     （2）delaySecs 任务的延时秒数
返回：返回一个控制COperation的句柄指针COperationHandler,如果在初始化任务池时候传入TIMER_UNKNOWN，那么当插入定时任务时候，就可能为COperationHandler 指向NULL。
*/
virtual boost::shared_ptr<COperationHandler> InsertTask(boost::shared_ptr<COperation> &pData, long lDelaySecs = 0) = 0;


/*
函数功能：启动任务池
*/
virtual void Run() = 0;


/*
函数功能：停止任务池
*/
virtual void Stop() = 0;


/*
函数功能：创建一个工作线程池
入参：（1）threadNum 线程的数量
 （2）maxSlot 为槽位数 当eType 为 TIMER_WHEEL 类型，代表定时器最大超时秒数，当eType为TIMER_HEAP代表最大定时任务数量
 （3）eType 位定时器类型
*/           
static boost::shared_ptr<CThreadPoolUtils> Create(unsigned int unThreadNum, long lMaxSlot = 360, TimerType eType = TIMER_UNKNOWN);
};
}

OperationHandler.hpp 插入调度任务池返回的句柄，用户可以同步支持任务等待。

#pragma once
#include "export.h"
#include <boost/shared_ptr.hpp>
#include "Operation.hpp"


namespace TaskUtils {


class  TASKUTILT_API COperationHandler
{
public:
virtual ~COperationHandler()throw(){}
/*
函数功能：获取原始执行任务智能指针
返回：COperation的智能指针
*/
virtual boost::shared_ptr<COperation> GetOperation() = 0;

/*
函数功能：等待用户一个异步任务的返回
参数：（1）lTimeout 等待超时时间，如果lTimeout为0则一直等待
返回：任务状态，其定义详见epxort.h   
*/
virtual unsigned long WaitResult(long lTimeout = 0) =0;
/*
函数功能：取消一个任务的调度
*/
virtual void Cancel() = 0;
};


}

      整个调度框架基于Boost ASIO 开发，支持定时多线程调度，即定时器任务与执行线程并发，定时器采用时间堆算法与信号量同步，精度不高，只能到1S， 定时器超时后，投递线程池操作。同步Handler返回采用信号量PV操作同步,代码支持Win32,X64,以及Linux。

具体代码可以参考GitHub

https://github.com/funnyleecat/taskUtils

最后

以上就是欢呼红酒为你收集整理的多线程定时调度模块设计的全部内容，希望文章能够帮你解决多线程定时调度模块设计所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。