MCPcopy Create free account

hub / github.com/ChunelFeng/CThreadPool / functions

Functions78 in github.com/ChunelFeng/CThreadPool

↓ 12 callersFunctionCGRAPH_ECHO
src/UtilsCtrl/UtilsFunction.h:27
↓ 4 callersMethodisOK
* 判断当前状态是否可行 * @return */
src/CBasic/CStatus.h:85
↓ 4 callersFunctionpopPoolTask
* 从线程池的队列中,获取任务 * @param task * @return */
src/UtilsCtrl/ThreadPool/Thread/UThreadBase.h:59
↓ 3 callersMethodsubmit
src/UtilsCtrl/ThreadPool/UThreadPool.cpp:71
↓ 2 callersMethodinit
src/UtilsCtrl/ThreadPool/UThreadPool.cpp:50
↓ 2 callersFunctionpopTask
* 从本地弹出一个任务 * @param task * @return */
src/UtilsCtrl/ThreadPool/Thread/UThreadPrimary.h:131
↓ 2 callersFunctionreset
* 清空所有任务内容 */
src/UtilsCtrl/ThreadPool/Thread/UThreadBase.h:112
↓ 2 callersFunctionrunTask
* 执行单个任务 * @param task */
src/UtilsCtrl/ThreadPool/Thread/UThreadBase.h:87
↓ 2 callersFunctionrunTasks
* 批量执行任务 * @param tasks */
src/UtilsCtrl/ThreadPool/Thread/UThreadBase.h:99
↓ 2 callersFunctionsetSchedParam
* 设置线程优先级,仅针对非windows平台使用 */
src/UtilsCtrl/ThreadPool/Thread/UThreadBase.h:126
↓ 2 callersFunctionstealTask
* 从其他线程窃取一个任务 * @param task * @return */
src/UtilsCtrl/ThreadPool/Thread/UThreadPrimary.h:151
↓ 1 callersFunctionUTask
src/UtilsCtrl/ThreadPool/Task/UTask.h:47
↓ 1 callersFunctionUTaskGroup
src/UtilsCtrl/ThreadPool/Task/UTaskGroup.h:29
↓ 1 callersFunctionadd
MyFunction.h:13
↓ 1 callersFunctioncalcPriority
src/UtilsCtrl/ThreadPool/Thread/UThreadBase.h:190
↓ 1 callersMethodcall
src/UtilsCtrl/ThreadPool/Task/UTask.h:30
↓ 1 callersFunctiondestroy
* 所有线程类的 destroy 函数应该是一样的 * 但是init函数不一样,因为线程构造函数不同 * @return */
src/UtilsCtrl/ThreadPool/Thread/UThreadBase.h:45
↓ 1 callersMethodgetCode
src/CBasic/CStatus.h:73
↓ 1 callersFunctionprocessTask
* 任务执行函数,从线程池的任务队列中获取信息 */
src/UtilsCtrl/ThreadPool/Thread/UThreadSecondary.h:83
↓ 1 callersFunctionprocessTask
* 获取并执行任务 * @return */
src/UtilsCtrl/ThreadPool/Thread/UThreadPrimary.h:102
↓ 1 callersFunctionprocessTasks
* 批量执行n个任务 */
src/UtilsCtrl/ThreadPool/Thread/UThreadSecondary.h:96
↓ 1 callersFunctionprocessTasks
* 获取批量执行task信息 */
src/UtilsCtrl/ThreadPool/Thread/UThreadPrimary.h:115
↓ 1 callersFunctionsetAffinity
* 设置线程亲和性,仅针对linux系统 */
src/UtilsCtrl/ThreadPool/Thread/UThreadBase.h:150
↓ 1 callersMethodsetConfig
src/UtilsCtrl/ThreadPool/UThreadPool.cpp:41
↓ 1 callersFunctiontutorial_threadpool_1
tutorial.cpp:15
↓ 1 callersFunctiontutorial_threadpool_2
tutorial.cpp:39
↓ 1 callersFunctiontutorial_threadpool_3
tutorial.cpp:91
FunctionCGRAPH_CONTAINER_MULTIPLY
src/UtilsCtrl/UtilsFunction.h:87
FunctionCGRAPH_CONTAINER_SUM
src/UtilsCtrl/UtilsFunction.h:71
FunctionCGRAPH_MAX
src/UtilsCtrl/UtilsFunction.h:103
FunctionCGRAPH_SUM
src/UtilsCtrl/UtilsFunction.h:120
MethodCSTATUS
src/CBasic/CStatus.h:24
MethodUThreadPool
src/UtilsCtrl/ThreadPool/UThreadPool.cpp:11
FunctionaddTask
* 添加一个任务 * @param task */
src/UtilsCtrl/ThreadPool/Task/UTaskGroup.h:41
FunctioncalcBatchTaskRatio
* 计算是否开启批量任务 * 开启条件:开关批量开启,并且 未开启非公平锁 * @return */
src/UtilsCtrl/ThreadPool/UThreadPoolConfig.h:53
Functionclear
* 清空任务组 */
src/UtilsCtrl/ThreadPool/Task/UTaskGroup.h:76
Methodconcat
MyFunction.h:24
MethodcreateSecondaryThread
src/UtilsCtrl/ThreadPool/UThreadPool.cpp:157
Methoddestroy
src/UtilsCtrl/ThreadPool/UThreadPool.cpp:108
Methoddispatch
src/UtilsCtrl/ThreadPool/UThreadPool.cpp:134
Functionempty
* 判定队列是否为空 * @return */
src/UtilsCtrl/ThreadPool/Queue/UAtomicQueue.h:118
Functionempty
* 判定队列是否为空 * @return */
src/UtilsCtrl/ThreadPool/Queue/UAtomicPriorityQueue.h:77
Functionfreeze
* 判断本线程是否需要被自动释放 * @return */
src/UtilsCtrl/ThreadPool/Thread/UThreadSecondary.h:110
MethodgenerateSession
* 生成唯一标识信息 * @return */
src/UtilsCtrl/UAllocator.h:60
FunctiongetSize
* 获取任务组大小 * @return */
src/UtilsCtrl/ThreadPool/Task/UTaskGroup.h:84
FunctiongetTtl
* 获取最大超时时间信息 * @return */
src/UtilsCtrl/ThreadPool/Task/UTaskGroup.h:69
Functioninit
src/UtilsCtrl/ThreadPool/Thread/UThreadPrimary.h:25
MethodisErr
* 判断当前状态是否可行 * @return */
src/CBasic/CStatus.h:93
Functionmain
tutorial.cpp:125
MethodmakeUniqueCObject
src/UtilsCtrl/UAllocator.h:51
FunctionminusBy5
MyFunction.h:17
Methodmonitor
src/UtilsCtrl/ThreadPool/UThreadPool.cpp:173
Methodmultiply
MyFunction.h:28
Functionoperator()
src/UtilsCtrl/ThreadPool/Task/UTask.h:33
Functionoperator<
src/UtilsCtrl/ThreadPool/Task/UTask.h:61
Functionoperator>
src/UtilsCtrl/ThreadPool/Task/UTask.h:57
Functionpush
* 传入数据 * @param value */
src/UtilsCtrl/ThreadPool/Queue/UAtomicQueue.h:106
Functionpush
* 传入数据 * @param value * @param priority 任务优先级,数字排序 * @return */
src/UtilsCtrl/ThreadPool/Queue/UAtomicPriorityQueue.h:66
Functionpush
* 向队列中写入信息 * @param task */
src/UtilsCtrl/ThreadPool/Queue/UWorkStealingQueue.h:30
Functionrun
src/UtilsCtrl/ThreadPool/Thread/UThreadSecondary.h:61
Functionrun
* 线程执行函数 * @return */
src/UtilsCtrl/ThreadPool/Thread/UThreadPrimary.h:66
MethodsafeMallocCObject
src/UtilsCtrl/UAllocator.h:35
FunctionsetOnFinished
* 设置执行完成后的回调函数 * @param onFinished * @return */
src/UtilsCtrl/ThreadPool/Task/UTaskGroup.h:60
MethodsetStatus
src/CBasic/CStatus.h:63
FunctionsetThreadPoolInfo
src/UtilsCtrl/ThreadPool/Thread/UThreadSecondary.h:34
FunctionsetThreadPoolInfo
* 注册线程池相关内容,需要在init之前使用 * @param index * @param poolTaskQueue * @param poolThreads * @param config */
src/UtilsCtrl/ThreadPool/Thread/UThreadPrimary.h:44
FunctionsetTtl
* 设置任务最大超时时间 * @param ttl */
src/UtilsCtrl/ThreadPool/Task/UTaskGroup.h:50
MethodtaskBased
src/UtilsCtrl/ThreadPool/Task/UTask.h:21
MethodtaskDerided
src/UtilsCtrl/ThreadPool/Task/UTask.h:29
FunctiontryPop
* 非阻塞式等待弹出 * @return */
src/UtilsCtrl/ThreadPool/Queue/UAtomicQueue.h:93
FunctiontryPop
* 弹出节点,从头部进行 * @param task * @return */
src/UtilsCtrl/ThreadPool/Queue/UWorkStealingQueue.h:48
FunctiontrySteal
* 窃取节点,从尾部进行 * @param task * @return */
src/UtilsCtrl/ThreadPool/Queue/UWorkStealingQueue.h:91
FunctionwaitPop
* 阻塞式等待弹出 * @return */
src/UtilsCtrl/ThreadPool/Queue/UAtomicQueue.h:80
Functionwhat
* 获取异常信息 * @return */
src/CBasic/CException.h:29
Function~CObject
src/CBasic/CObject.h:47
Function~UThreadBase
src/UtilsCtrl/ThreadPool/Thread/UThreadBase.h:35
Method~UThreadPool
src/UtilsCtrl/ThreadPool/UThreadPool.cpp:31
Method~taskBased
src/UtilsCtrl/ThreadPool/Task/UTask.h:23