mirror of
https://gitee.com/acl-dev/acl.git
synced 2024-12-15 09:20:52 +08:00
92 lines
2.0 KiB
C++
92 lines
2.0 KiB
C++
#pragma once
|
|
|
|
namespace acl
|
|
{
|
|
|
|
/**
|
|
* 纯虚函数：线程任务类，该类实例的 run 方法是在子线程中被执行的
|
|
*/
|
|
class ACL_CPP_API thread_job
|
|
{
|
|
public:
|
|
thread_job() {}
|
|
virtual ~thread_job() {}
|
|
|
|
/**
|
|
* 纯虚函数，子类必须实现此函数，该函数在子线程中执行
|
|
* @return {void*} 线程退出前返回的参数
|
|
*/
|
|
virtual void* run() = 0;
|
|
};
|
|
|
|
/**
|
|
* 线程纯虚类，该类的接口定义类似于 Java 的接口定义，子类需要实现
|
|
* 基类的纯虚函数，使用者通过调用 thread::start() 启动线程过程
|
|
*/
|
|
class ACL_CPP_API thread : public thread_job
|
|
{
|
|
public:
|
|
thread();
|
|
virtual ~thread();
|
|
|
|
/**
|
|
* 开始启动线程过程，一旦该函数被调用，则会立即启动一个新的
|
|
* 子线程，在子线程中执行基类 thread_job::run 过程
|
|
* @return {bool} 是否成功创建线程
|
|
*/
|
|
bool start();
|
|
|
|
/**
|
|
* 当创建线程时为非 detachable 状态，则必须调用此函数等待线程结束；
|
|
* 若创建线程时为 detachable 状态时，禁止调用本函数
|
|
* @param out {void**} 当该参数非空指针时，该参数用来存放
|
|
* 线程退出前返回的参数
|
|
* @return {bool} 是否成功
|
|
*/
|
|
bool wait(void** out = NULL);
|
|
|
|
/**
|
|
* 在调用 start 前调用此函数可以设置所创建线程是否为
|
|
* 分离 (detachable) 状态；如果未调用此函数，则所创建
|
|
* 的线程默认为分离状态
|
|
* @param yes {bool} 是否为分离状态
|
|
* @return {thread&}
|
|
*/
|
|
thread& set_detachable(bool yes);
|
|
|
|
/**
|
|
* 在调用 start 前调用此函数可以设置所创建线程的堆栈大小
|
|
* @param size {size_t} 线程堆栈大小，当该值为 0 或未
|
|
* 调用此函数，则所创建的线程堆栈大小为系统的默认值
|
|
* @return {thread&}
|
|
*/
|
|
thread& set_stacksize(size_t size);
|
|
|
|
/**
|
|
* 在调用 start 后调用此函数可以获得所创建线程的 id 号
|
|
* @return {unsigned long}
|
|
*/
|
|
unsigned long thread_id() const;
|
|
|
|
/**
|
|
* 当前调用者所在线程的线程 id 号
|
|
* @return {unsigned long}
|
|
*/
|
|
static unsigned long thread_self();
|
|
|
|
private:
|
|
bool detachable_;
|
|
size_t stack_size_;
|
|
#if defined(_WIN32) || defined(_WIN64)
|
|
void* thread_;
|
|
unsigned long thread_id_;
|
|
#else
|
|
pthread_t thread_;
|
|
unsigned long thread_id_;
|
|
#endif
|
|
void* return_arg_;
|
|
static void* thread_run(void* arg);
|
|
};
|
|
|
|
} // namespace acl
|