126 lines
3.5 KiB
C++
126 lines
3.5 KiB
C++
//
|
|
// cthread.hpp
|
|
// Net
|
|
//
|
|
// Created by 胡一兵 on 2019/1/14.
|
|
// Copyright © 2019年 Bakantu. All rights reserved.
|
|
//
|
|
|
|
#ifndef cthread_h
|
|
#define cthread_h
|
|
|
|
#include "type.h"
|
|
#include "cpart.h"
|
|
#include "cmap.h"
|
|
#include "server.h"
|
|
|
|
class CThread;
|
|
class Server;
|
|
|
|
//线程信息记录结构体
|
|
struct thread_args{
|
|
// 子线程编号
|
|
unsigned long tid;
|
|
// 指向计算任务
|
|
CThread *pct;
|
|
// 指向计算模块
|
|
CPart *pcp;
|
|
// 储存计算模块调用的返回值
|
|
int rtn;
|
|
};
|
|
|
|
//并行任务处理进程信息结构体
|
|
struct line_process{
|
|
// 是否开启并行任务管理
|
|
bool if_als = false;
|
|
// 已经释放的子线程
|
|
list<struct thread_args *>child_finished;
|
|
// 子线程管理状态记录
|
|
map<unsigned long,pthread_t> threads;
|
|
// 记录计算模块对应的线程id
|
|
map<const CPart * const,unsigned long> cpttid;
|
|
// 计算模块处理队列
|
|
list<CPart *> line;
|
|
};
|
|
|
|
//计算任务类
|
|
class CThread{
|
|
public:
|
|
// 计算任务图纸
|
|
const CMap * const p_map;
|
|
// 此计算进程中计算模块的传入参数数据列表
|
|
map<string,vector<void *>> rargs;
|
|
// 此计算进程的计算模块的传出参数数据列表
|
|
map<string,vector<void *>> rargs_out;
|
|
// 计算模块是否已经解决
|
|
map<string,bool> ifsolved;
|
|
// 计算模块是否有数据
|
|
map<string,bool> if_rargs;
|
|
// tid生成的依据
|
|
unsigned long idxtid;
|
|
// 并行线程的个数
|
|
int thdnum;
|
|
// 并行任务处理进程
|
|
struct line_process lpcs;
|
|
// 守护进程定时器
|
|
struct itimerval itrl;
|
|
|
|
|
|
// 使用图结构管理结构来构造计算进程管理结构
|
|
CThread(CMap *tp_map, int thdnum = 4);
|
|
~CThread();
|
|
|
|
// 添加相关计算模块的传入参数
|
|
void AddArgs(string name, void *pvle){
|
|
if(main_pool.b_get(pvle) == nullptr) throw "information lost";
|
|
auto argil = rargs.find(name);
|
|
argil->second.push_back(pvle);
|
|
}
|
|
|
|
// 添加相关计算模块的传出参数
|
|
void AddArgsOut(string name, void *pvle){
|
|
if(main_pool.b_get(pvle) == nullptr) throw "information lost";
|
|
auto argol = rargs_out.find(name);
|
|
argol->second.push_back(pvle);
|
|
}
|
|
|
|
// 设置守护进程
|
|
void SetDaemon(void);
|
|
|
|
// 守护进程
|
|
void Daemon(void);
|
|
// 分析图结构来构造新的处理队列
|
|
void Analyse(void);
|
|
// 执行处理队列
|
|
void DoLine(void);
|
|
// 通过子线程所属的模块名找到子线程的id
|
|
long FindChildPCS(string name);
|
|
// 取消子线程
|
|
int CancelChildPCS(unsigned long tid);
|
|
// 处理数据包
|
|
int GetCPUResult(struct compute_result *);
|
|
// 标记计算模块
|
|
static void SignedCpart(void *args, CPart *pcp);
|
|
// 导出数据包
|
|
struct compute_result BuildCPUResult(CPart *);
|
|
// 发送数据包到服务器
|
|
int SendCPUResult(Server *,struct compute_result);
|
|
// 从服务器中获得数据包
|
|
vector<struct compute_result> GetCPURFromServer(Server *);
|
|
// 查询计算模块是否已经解决
|
|
CPart *IfCPTSolved(string name);
|
|
// 建立新线程执行计算模块
|
|
static void * NewThread(void *);
|
|
// 为计算模块的调用准备输入参数
|
|
static void PrepareArgsIn(CThread *pct,CPart *);
|
|
// 获得计算模块执行后的输出参数
|
|
static void GetArgsOut(CThread *pct,CPart *);
|
|
// 通知计算任务子线程即将结束
|
|
static void ChildThreadFSH(struct thread_args *);
|
|
};
|
|
|
|
//注册任务进程时钟调用
|
|
void setTrdClock(CThread *ptd);
|
|
|
|
#endif /* cthread_h */
|