Types
| Name | Value | Description |
|---|---|---|
Job | std::function<void(std::size_t)> |
Constructors
| Name | Description |
|---|---|
WorkerPoolParallel() |
Destructors
| Name | Description |
|---|---|
~WorkerPoolParallel() |
Functions
| Access | Return | Modifier | Name | Description |
|---|---|---|---|---|
public | bool | static | sIsWorker() | |
public | void | |||
public | void | detach( std::function<void()> inJob ) | ||
private | void | shutdown() | ||
private | void | ensureWorkers() | ||
private | void | loop() | ||
private | bool | const | hasWork() |
Members
| Access | Type | Modifier | Name | Description |
|---|---|---|---|---|
public | job | |||
public | std::size_t | next | ||
public | std::size_t | count | ||
public | std::size_t | remaining | ||
public | std::exception_ptr | error | ||
public | std::condition_variable | done | ||
private | std::mutex | m_mutex | ||
private | std::condition_variable | m_signal | ||
private | std::deque<std::shared_ptr<Batch>> | m_batches | ||
private | std::vector<std::thread> | m_workers | ||
private | bool | m_bShutdown |