Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/ChunelFeng/CThreadPool
/ functions
Functions
78 in github.com/ChunelFeng/CThreadPool
⨍
Functions
78
◇
Types & classes
6
↓ 12 callers
Function
CGRAPH_ECHO
src/UtilsCtrl/UtilsFunction.h:27
↓ 4 callers
Method
isOK
* 判断当前状态是否可行 * @return */
src/CBasic/CStatus.h:85
↓ 4 callers
Function
popPoolTask
* 从线程池的队列中,获取任务 * @param task * @return */
src/UtilsCtrl/ThreadPool/Thread/UThreadBase.h:59
↓ 3 callers
Method
submit
src/UtilsCtrl/ThreadPool/UThreadPool.cpp:71
↓ 2 callers
Method
init
src/UtilsCtrl/ThreadPool/UThreadPool.cpp:50
↓ 2 callers
Function
popTask
* 从本地弹出一个任务 * @param task * @return */
src/UtilsCtrl/ThreadPool/Thread/UThreadPrimary.h:131
↓ 2 callers
Function
reset
* 清空所有任务内容 */
src/UtilsCtrl/ThreadPool/Thread/UThreadBase.h:112
↓ 2 callers
Function
runTask
* 执行单个任务 * @param task */
src/UtilsCtrl/ThreadPool/Thread/UThreadBase.h:87
↓ 2 callers
Function
runTasks
* 批量执行任务 * @param tasks */
src/UtilsCtrl/ThreadPool/Thread/UThreadBase.h:99
↓ 2 callers
Function
setSchedParam
* 设置线程优先级,仅针对非windows平台使用 */
src/UtilsCtrl/ThreadPool/Thread/UThreadBase.h:126
↓ 2 callers
Function
stealTask
* 从其他线程窃取一个任务 * @param task * @return */
src/UtilsCtrl/ThreadPool/Thread/UThreadPrimary.h:151
↓ 1 callers
Function
UTask
src/UtilsCtrl/ThreadPool/Task/UTask.h:47
↓ 1 callers
Function
UTaskGroup
src/UtilsCtrl/ThreadPool/Task/UTaskGroup.h:29
↓ 1 callers
Function
add
MyFunction.h:13
↓ 1 callers
Function
calcPriority
src/UtilsCtrl/ThreadPool/Thread/UThreadBase.h:190
↓ 1 callers
Method
call
src/UtilsCtrl/ThreadPool/Task/UTask.h:30
↓ 1 callers
Function
destroy
* 所有线程类的 destroy 函数应该是一样的 * 但是init函数不一样,因为线程构造函数不同 * @return */
src/UtilsCtrl/ThreadPool/Thread/UThreadBase.h:45
↓ 1 callers
Method
getCode
src/CBasic/CStatus.h:73
↓ 1 callers
Function
processTask
* 任务执行函数,从线程池的任务队列中获取信息 */
src/UtilsCtrl/ThreadPool/Thread/UThreadSecondary.h:83
↓ 1 callers
Function
processTask
* 获取并执行任务 * @return */
src/UtilsCtrl/ThreadPool/Thread/UThreadPrimary.h:102
↓ 1 callers
Function
processTasks
* 批量执行n个任务 */
src/UtilsCtrl/ThreadPool/Thread/UThreadSecondary.h:96
↓ 1 callers
Function
processTasks
* 获取批量执行task信息 */
src/UtilsCtrl/ThreadPool/Thread/UThreadPrimary.h:115
↓ 1 callers
Function
setAffinity
* 设置线程亲和性,仅针对linux系统 */
src/UtilsCtrl/ThreadPool/Thread/UThreadBase.h:150
↓ 1 callers
Method
setConfig
src/UtilsCtrl/ThreadPool/UThreadPool.cpp:41
↓ 1 callers
Function
tutorial_threadpool_1
tutorial.cpp:15
↓ 1 callers
Function
tutorial_threadpool_2
tutorial.cpp:39
↓ 1 callers
Function
tutorial_threadpool_3
tutorial.cpp:91
Function
CGRAPH_CONTAINER_MULTIPLY
src/UtilsCtrl/UtilsFunction.h:87
Function
CGRAPH_CONTAINER_SUM
src/UtilsCtrl/UtilsFunction.h:71
Function
CGRAPH_MAX
src/UtilsCtrl/UtilsFunction.h:103
Function
CGRAPH_SUM
src/UtilsCtrl/UtilsFunction.h:120
Method
CSTATUS
src/CBasic/CStatus.h:24
Method
UThreadPool
src/UtilsCtrl/ThreadPool/UThreadPool.cpp:11
Function
addTask
* 添加一个任务 * @param task */
src/UtilsCtrl/ThreadPool/Task/UTaskGroup.h:41
Function
calcBatchTaskRatio
* 计算是否开启批量任务 * 开启条件:开关批量开启,并且 未开启非公平锁 * @return */
src/UtilsCtrl/ThreadPool/UThreadPoolConfig.h:53
Function
clear
* 清空任务组 */
src/UtilsCtrl/ThreadPool/Task/UTaskGroup.h:76
Method
concat
MyFunction.h:24
Method
createSecondaryThread
src/UtilsCtrl/ThreadPool/UThreadPool.cpp:157
Method
destroy
src/UtilsCtrl/ThreadPool/UThreadPool.cpp:108
Method
dispatch
src/UtilsCtrl/ThreadPool/UThreadPool.cpp:134
Function
empty
* 判定队列是否为空 * @return */
src/UtilsCtrl/ThreadPool/Queue/UAtomicQueue.h:118
Function
empty
* 判定队列是否为空 * @return */
src/UtilsCtrl/ThreadPool/Queue/UAtomicPriorityQueue.h:77
Function
freeze
* 判断本线程是否需要被自动释放 * @return */
src/UtilsCtrl/ThreadPool/Thread/UThreadSecondary.h:110
Method
generateSession
* 生成唯一标识信息 * @return */
src/UtilsCtrl/UAllocator.h:60
Function
getSize
* 获取任务组大小 * @return */
src/UtilsCtrl/ThreadPool/Task/UTaskGroup.h:84
Function
getTtl
* 获取最大超时时间信息 * @return */
src/UtilsCtrl/ThreadPool/Task/UTaskGroup.h:69
Function
init
src/UtilsCtrl/ThreadPool/Thread/UThreadPrimary.h:25
Method
isErr
* 判断当前状态是否可行 * @return */
src/CBasic/CStatus.h:93
Function
main
tutorial.cpp:125
Method
makeUniqueCObject
src/UtilsCtrl/UAllocator.h:51
Function
minusBy5
MyFunction.h:17
Method
monitor
src/UtilsCtrl/ThreadPool/UThreadPool.cpp:173
Method
multiply
MyFunction.h:28
Function
operator()
src/UtilsCtrl/ThreadPool/Task/UTask.h:33
Function
operator<
src/UtilsCtrl/ThreadPool/Task/UTask.h:61
Function
operator>
src/UtilsCtrl/ThreadPool/Task/UTask.h:57
Function
push
* 传入数据 * @param value */
src/UtilsCtrl/ThreadPool/Queue/UAtomicQueue.h:106
Function
push
* 传入数据 * @param value * @param priority 任务优先级,数字排序 * @return */
src/UtilsCtrl/ThreadPool/Queue/UAtomicPriorityQueue.h:66
Function
push
* 向队列中写入信息 * @param task */
src/UtilsCtrl/ThreadPool/Queue/UWorkStealingQueue.h:30
Function
run
src/UtilsCtrl/ThreadPool/Thread/UThreadSecondary.h:61
Function
run
* 线程执行函数 * @return */
src/UtilsCtrl/ThreadPool/Thread/UThreadPrimary.h:66
Method
safeMallocCObject
src/UtilsCtrl/UAllocator.h:35
Function
setOnFinished
* 设置执行完成后的回调函数 * @param onFinished * @return */
src/UtilsCtrl/ThreadPool/Task/UTaskGroup.h:60
Method
setStatus
src/CBasic/CStatus.h:63
Function
setThreadPoolInfo
src/UtilsCtrl/ThreadPool/Thread/UThreadSecondary.h:34
Function
setThreadPoolInfo
* 注册线程池相关内容,需要在init之前使用 * @param index * @param poolTaskQueue * @param poolThreads * @param config */
src/UtilsCtrl/ThreadPool/Thread/UThreadPrimary.h:44
Function
setTtl
* 设置任务最大超时时间 * @param ttl */
src/UtilsCtrl/ThreadPool/Task/UTaskGroup.h:50
Method
taskBased
src/UtilsCtrl/ThreadPool/Task/UTask.h:21
Method
taskDerided
src/UtilsCtrl/ThreadPool/Task/UTask.h:29
Function
tryPop
* 非阻塞式等待弹出 * @return */
src/UtilsCtrl/ThreadPool/Queue/UAtomicQueue.h:93
Function
tryPop
* 弹出节点,从头部进行 * @param task * @return */
src/UtilsCtrl/ThreadPool/Queue/UWorkStealingQueue.h:48
Function
trySteal
* 窃取节点,从尾部进行 * @param task * @return */
src/UtilsCtrl/ThreadPool/Queue/UWorkStealingQueue.h:91
Function
waitPop
* 阻塞式等待弹出 * @return */
src/UtilsCtrl/ThreadPool/Queue/UAtomicQueue.h:80
Function
what
* 获取异常信息 * @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