test/acl
1
0
Fork 0
mirror of https://gitee.com/acl-dev/acl.git synced 2024-12-14 00:40:55 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity
0eb19221a0
acl/lib_acl_cpp/include/acl_cpp/stdlib/thread_pool.hpp

126 lines
3.1 KiB
C++
Raw Normal View History

Revert "All source code have been changed to use utf8 charset with BOM header!" This reverts commit 15d999759eabbf2568053d9d864e06ad876a5593.
2019-07-28 10:31:56 +08:00
#pragma once
safety & feature: add nocopyable limit for many class to avoid potential problem
2019-05-09 13:57:51 +08:00
#include "noncopyable.hpp"
整理了一些文件格式
2014-11-19 00:25:21 +08:00
struct acl_pthread_pool_t;
struct acl_pthread_pool_attr_t;
namespace acl
{
class thread_job;
/**
Revert "All source code have been changed to use utf8 charset with BOM header!" This reverts commit 15d999759eabbf2568053d9d864e06ad876a5593.
2019-07-28 10:31:56 +08:00
* <EFBFBD>̳߳ع<EFBFBD><EFBFBD><EFBFBD><EFBFBD>࣬<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ڹ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>̳߳<EFBFBD><EFBFBD>е<EFBFBD><EFBFBD>߳<EFBFBD><EFBFBD>ǰ<EFBFBD>פ<EFBFBD><EFBFBD><EFBFBD><EFBFBD>(<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>߳̿<EFBFBD><EFBFBD><EFBFBD>һ<EFBFBD><EFBFBD>ʱ<EFBFBD><EFBFBD><EFBFBD><EFBFBD>
* <EFBFBD>Զ<EFBFBD><EFBFBD>˳<EFBFBD>)<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ǵ<EFBFBD><EFBFBD>麯<EFBFBD><EFBFBD><EFBFBD><EFBFBD>thread_on_init(<EFBFBD>̳߳<EFBFBD><EFBFBD>е<EFBFBD>ij<EFBFBD><EFBFBD><EFBFBD>̵߳<EFBFBD>һ<EFBFBD><EFBFBD>
* <EFBFBD><EFBFBD><EFBFBD><EFBFBD>ʱ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ȵ<EFBFBD><EFBFBD>ô˺<EFBFBD><EFBFBD><EFBFBD>)<EFBFBD><EFBFBD>thread_on_exit(<EFBFBD>̳߳<EFBFBD><EFBFBD>е<EFBFBD>ij<EFBFBD><EFBFBD><EFBFBD>߳<EFBFBD><EFBFBD>˳<EFBFBD>ʱ<EFBFBD><EFBFBD><EFBFBD>ô˺<EFBFBD><EFBFBD><EFBFBD>)
整理了一些文件格式
2014-11-19 00:25:21 +08:00
*/
safety & feature: add nocopyable limit for many class to avoid potential problem
2019-05-09 13:57:51 +08:00
class ACL_CPP_API thread_pool : public noncopyable
整理了一些文件格式
2014-11-19 00:25:21 +08:00
{
public:
safety & feature: add nocopyable limit for many class to avoid potential problem
2019-05-09 13:57:51 +08:00
thread_pool(void);
virtual ~thread_pool(void);
整理了一些文件格式
2014-11-19 00:25:21 +08:00
/**
Revert "All source code have been changed to use utf8 charset with BOM header!" This reverts commit 15d999759eabbf2568053d9d864e06ad876a5593.
2019-07-28 10:31:56 +08:00
* <EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>̳߳أ<EFBFBD><EFBFBD>ڴ<EFBFBD><EFBFBD><EFBFBD><EFBFBD>̳߳ض<EFBFBD><EFBFBD><EFBFBD><EFBFBD>󣬱<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ȵ<EFBFBD><EFBFBD>ô˺<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>̳߳<EFBFBD>
整理了一些文件格式
2014-11-19 00:25:21 +08:00
*/
safety & feature: add nocopyable limit for many class to avoid potential problem
2019-05-09 13:57:51 +08:00
void start(void);
整理了一些文件格式
2014-11-19 00:25:21 +08:00
/**
Revert "All source code have been changed to use utf8 charset with BOM header!" This reverts commit 15d999759eabbf2568053d9d864e06ad876a5593.
2019-07-28 10:31:56 +08:00
* ֹͣ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>̳߳أ<EFBFBD><EFBFBD><EFBFBD><EFBFBD>ͷ<EFBFBD><EFBFBD>̳߳<EFBFBD><EFBFBD><EFBFBD>Դ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ô˺<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ʹ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>߳<EFBFBD><EFBFBD>˳<EFBFBD><EFBFBD><EFBFBD>
* <EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ͷű<EFBFBD>ʵ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ʵ<EFBFBD><EFBFBD><EFBFBD>Ƕ<EFBFBD>̬<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>û<EFBFBD>Ӧ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ͷ<EFBFBD><EFBFBD><EFBFBD>ʵ<EFBFBD><EFBFBD><EFBFBD><EFBFBD>
* <EFBFBD>ڵ<EFBFBD><EFBFBD>ñ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>̳߳ع<EFBFBD><EFBFBD>̣<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>µ<EFBFBD><EFBFBD><EFBFBD> start <EFBFBD><EFBFBD><EFBFBD><EFBFBD>
整理了一些文件格式
2014-11-19 00:25:21 +08:00
*/
safety & feature: add nocopyable limit for many class to avoid potential problem
2019-05-09 13:57:51 +08:00
void stop(void);
整理了一些文件格式
2014-11-19 00:25:21 +08:00
/**
Revert "All source code have been changed to use utf8 charset with BOM header!" This reverts commit 15d999759eabbf2568053d9d864e06ad876a5593.
2019-07-28 10:31:56 +08:00
* <EFBFBD>ȴ<EFBFBD><EFBFBD>̳߳<EFBFBD><EFBFBD>е<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>̳߳<EFBFBD>ִ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
整理了一些文件格式
2014-11-19 00:25:21 +08:00
*/
safety & feature: add nocopyable limit for many class to avoid potential problem
2019-05-09 13:57:51 +08:00
void wait(void);
整理了一些文件格式
2014-11-19 00:25:21 +08:00
/**
Revert "All source code have been changed to use utf8 charset with BOM header!" This reverts commit 15d999759eabbf2568053d9d864e06ad876a5593.
2019-07-28 10:31:56 +08:00
* <EFBFBD><EFBFBD>һ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>񽻸<EFBFBD><EFBFBD>̳߳<EFBFBD><EFBFBD>е<EFBFBD>һ<EFBFBD><EFBFBD><EFBFBD>߳<EFBFBD>ȥִ<EFBFBD>У<EFBFBD><EFBFBD>̳߳<EFBFBD><EFBFBD>е<EFBFBD>
* <EFBFBD>̻߳<EFBFBD>ִ<EFBFBD>и<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>е<EFBFBD> run <EFBFBD><EFBFBD><EFBFBD><EFBFBD>
* @param job {thread_job*} <EFBFBD>߳<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
* @return {bool} <EFBFBD>Ƿ<EFBFBD><EFBFBD>ɹ<EFBFBD>
整理了一些文件格式
2014-11-19 00:25:21 +08:00
*/
bool run(thread_job* job);
/**
Revert "All source code have been changed to use utf8 charset with BOM header!" This reverts commit 15d999759eabbf2568053d9d864e06ad876a5593.
2019-07-28 10:31:56 +08:00
* <EFBFBD><EFBFBD>һ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>񽻸<EFBFBD><EFBFBD>̳߳<EFBFBD><EFBFBD>е<EFBFBD>һ<EFBFBD><EFBFBD><EFBFBD>߳<EFBFBD>ȥִ<EFBFBD>У<EFBFBD><EFBFBD>̳߳<EFBFBD><EFBFBD>е<EFBFBD>
* <EFBFBD>̻߳<EFBFBD>ִ<EFBFBD>и<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>е<EFBFBD> run <EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ú<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD> run <EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ȫ<EFBFBD><EFBFBD>ͬ<EFBFBD><EFBFBD>ֻ<EFBFBD><EFBFBD>Ϊ<EFBFBD><EFBFBD>
* ʹ JAVA <EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ա<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ϊ<EFBFBD><EFBFBD>Ϥ<EFBFBD><EFBFBD><EFBFBD>ṩ<EFBFBD>˴˽ӿ<EFBFBD>
* @param job {thread_job*} <EFBFBD>߳<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
* @return {bool} <EFBFBD>Ƿ<EFBFBD><EFBFBD>ɹ<EFBFBD>
整理了一些文件格式
2014-11-19 00:25:21 +08:00
*/
bool execute(thread_job* job);
/**
Revert "All source code have been changed to use utf8 charset with BOM header!" This reverts commit 15d999759eabbf2568053d9d864e06ad876a5593.
2019-07-28 10:31:56 +08:00
* <EFBFBD>ڵ<EFBFBD><EFBFBD><EFBFBD> start ǰ<EFBFBD><EFBFBD><EFBFBD>ô˺<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>̵߳Ķ<EFBFBD>ջ<EFBFBD><EFBFBD>С
* @param size {size_t} <EFBFBD>̶߳<EFBFBD>ջ<EFBFBD><EFBFBD>С<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ֵΪ 0 <EFBFBD><EFBFBD>δ
* <EFBFBD><EFBFBD><EFBFBD>ô˺<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>̶߳<EFBFBD>ջ<EFBFBD><EFBFBD>СΪϵͳ<EFBFBD><EFBFBD>Ĭ<EFBFBD><EFBFBD>ֵ
整理了一些文件格式
2014-11-19 00:25:21 +08:00
* @return {thread&}
*/
thread_pool& set_stacksize(size_t size);
/**
Revert "All source code have been changed to use utf8 charset with BOM header!" This reverts commit 15d999759eabbf2568053d9d864e06ad876a5593.
2019-07-28 10:31:56 +08:00
* <EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>̳߳<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD≯߳<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
* @param max {size_t} <EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>߳<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ô˺<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ڲ<EFBFBD>ȱʡֵΪ 100
整理了一些文件格式
2014-11-19 00:25:21 +08:00
* @return {thread_pool&}
*/
thread_pool& set_limit(size_t max);
add get_limit() in thread_pool to get the threads count limit in the threads pool.
2020-07-23 10:39:39 +08:00
/**
* <EFBFBD><EFBFBD><EFBFBD>õ<EFBFBD>ǰ<EFBFBD>̳߳<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>߳<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
* @return {size_t}
*/
size_t get_limit(void) const;
整理了一些文件格式
2014-11-19 00:25:21 +08:00
/**
Revert "All source code have been changed to use utf8 charset with BOM header!" This reverts commit 15d999759eabbf2568053d9d864e06ad876a5593.
2019-07-28 10:31:56 +08:00
* <EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>̳߳<EFBFBD><EFBFBD>п<EFBFBD><EFBFBD><EFBFBD><EFBFBD>̵߳ij<EFBFBD>ʱ<EFBFBD>˳<EFBFBD>ʱ<EFBFBD><EFBFBD>
* @param ttl {int} <EFBFBD><EFBFBD><EFBFBD>г<EFBFBD>ʱʱ<EFBFBD><EFBFBD>(<EFBFBD><EFBFBD>)<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ô˺<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ڲ<EFBFBD>ȱʡΪ 0
整理了一些文件格式
2014-11-19 00:25:21 +08:00
* @return {thread_pool&}
*/
thread_pool& set_idle(int ttl);
/**
Revert "All source code have been changed to use utf8 charset with BOM header!" This reverts commit 15d999759eabbf2568053d9d864e06ad876a5593.
2019-07-28 10:31:56 +08:00
* <EFBFBD><EFBFBD><EFBFBD>õ<EFBFBD>ǰ<EFBFBD>̳߳<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>̵߳<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
* @return {int} <EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>̳߳<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>̵߳<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>δͨ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD> start
* <EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>̳߳ع<EFBFBD><EFBFBD>̣<EFBFBD><EFBFBD><EFBFBD><EFBFBD>ú<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD> -1
整理了一些文件格式
2014-11-19 00:25:21 +08:00
*/
safety & feature: add nocopyable limit for many class to avoid potential problem
2019-05-09 13:57:51 +08:00
int threads_count(void) const;
整理了一些文件格式
2014-11-19 00:25:21 +08:00
/**
Revert "All source code have been changed to use utf8 charset with BOM header!" This reverts commit 15d999759eabbf2568053d9d864e06ad876a5593.
2019-07-28 10:31:56 +08:00
* <EFBFBD><EFBFBD><EFBFBD>õ<EFBFBD>ǰ<EFBFBD>̳߳<EFBFBD><EFBFBD><EFBFBD>δ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
* @return {int} <EFBFBD><EFBFBD><EFBFBD>̳߳ػ<EFBFBD>δ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>(<EFBFBD><EFBFBD>δ<EFBFBD><EFBFBD><EFBFBD><EFBFBD> start)<EFBFBD><EFBFBD><EFBFBD>Ѿ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>򷵻<EFBFBD> -1
整理了一些文件格式
2014-11-19 00:25:21 +08:00
*/
safety & feature: add nocopyable limit for many class to avoid potential problem
2019-05-09 13:57:51 +08:00
int task_qlen(void) const;
整理了一些文件格式
2014-11-19 00:25:21 +08:00
protected:
/**
Revert "All source code have been changed to use utf8 charset with BOM header!" This reverts commit 15d999759eabbf2568053d9d864e06ad876a5593.
2019-07-28 10:31:56 +08:00
* <EFBFBD><EFBFBD><EFBFBD>̳߳<EFBFBD><EFBFBD>е<EFBFBD><EFBFBD><EFBFBD><EFBFBD>̵߳<EFBFBD>һ<EFBFBD>α<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ʱ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>麯<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ã<EFBFBD>
* <EFBFBD>û<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>Լ<EFBFBD><EFBFBD><EFBFBD>ʵ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>һЩ<EFBFBD><EFBFBD>ʼ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
* @return {bool} <EFBFBD><EFBFBD>ʼ<EFBFBD><EFBFBD><EFBFBD>Ƿ<EFBFBD><EFBFBD>ɹ<EFBFBD>
整理了一些文件格式
2014-11-19 00:25:21 +08:00
*/
safety & feature: add nocopyable limit for many class to avoid potential problem
2019-05-09 13:57:51 +08:00
virtual bool thread_on_init(void) { return true; }
整理了一些文件格式
2014-11-19 00:25:21 +08:00
/**
Revert "All source code have been changed to use utf8 charset with BOM header!" This reverts commit 15d999759eabbf2568053d9d864e06ad876a5593.
2019-07-28 10:31:56 +08:00
* <EFBFBD><EFBFBD><EFBFBD>̳߳<EFBFBD><EFBFBD>е<EFBFBD><EFBFBD><EFBFBD><EFBFBD>߳<EFBFBD><EFBFBD>˳<EFBFBD>ʱ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>麯<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ã<EFBFBD><EFBFBD>û<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
* <EFBFBD><EFBFBD><EFBFBD>Լ<EFBFBD><EFBFBD><EFBFBD>ʵ<EFBFBD><EFBFBD> <EFBFBD><EFBFBD><EFBFBD><EFBFBD>һЩ<EFBFBD><EFBFBD>Դ<EFBFBD>ͷŹ<EFBFBD><EFBFBD><EFBFBD>
整理了一些文件格式
2014-11-19 00:25:21 +08:00
*/
safety & feature: add nocopyable limit for many class to avoid potential problem
2019-05-09 13:57:51 +08:00
virtual void thread_on_exit(void) {}
整理了一些文件格式
2014-11-19 00:25:21 +08:00
private:
size_t stack_size_;
size_t threads_limit_;
int thread_idle_;
acl_pthread_pool_t* thr_pool_;
acl_pthread_pool_attr_t* thr_attr_;
static void thread_run(void* arg);
static int thread_init(void* arg);
static void thread_exit(void* arg);
};
} // namespace acl
Reference in New Issue Copy Permalink