|
Distributed Cache
|

Public Member Functions | |
| WorkerPool (std::function< void(T)> executor, int threadCount=0, bool exitWhenDone=true) | |
| void | insert (T obj) |
| void | insert (std::vector< T > &objects) |
| void | start (int c=0) |
| void | threadRunner () |
| void | join () |
Private Attributes | |
| std::function< void(T)> | executor |
| std::queue< T > | queue |
| std::mutex | queueLock |
| std::vector< std::thread > | threads |
| int | threadCount |
|
inline |
|
inline |
|
inline |

|
inline |

|
inline |


|
inline |

|
private |
|
private |
|
private |
|
private |
|
private |
1.8.18