| Index: native_client_sdk/src/libraries/sdk_util/thread_pool.h
|
| diff --git a/native_client_sdk/src/libraries/sdk_util/thread_pool.h b/native_client_sdk/src/libraries/sdk_util/thread_pool.h
|
| index 760b3f715db0fea044eae27bccf622ebad52994e..7482347f5dbf0ce6dffbe3745ae2e8db7908cb59 100644
|
| --- a/native_client_sdk/src/libraries/sdk_util/thread_pool.h
|
| +++ b/native_client_sdk/src/libraries/sdk_util/thread_pool.h
|
| @@ -10,6 +10,8 @@
|
| #include <pthread.h>
|
| #include <semaphore.h>
|
|
|
| +#include "sdk_util/atomicops.h"
|
| +
|
| // typdef helper for work function
|
| typedef void (*WorkFunction)(int task_index, void* data);
|
|
|
| @@ -33,7 +35,7 @@ class ThreadPool {
|
| static void* WorkerThreadEntry(void* data);
|
| void PostExitAndJoinAll();
|
| pthread_t* threads_;
|
| - int counter_;
|
| + Atomic32 counter_;
|
| const int num_threads_;
|
| bool exiting_;
|
| void* user_data_;
|
|
|