chromium/third_party/unrar/src/threadpool.cpp

#include "rar.hpp"

#ifdef RAR_SMP
#include "threadmisc.cpp"

#ifdef _WIN_ALL
int ThreadPool::ThreadPriority=THREAD_PRIORITY_NORMAL;
#endif

ThreadPool::ThreadPool(uint MaxThreads)
{ … }


ThreadPool::~ThreadPool()
{ … }


void ThreadPool::CreateThreads()
{ … }


NATIVE_THREAD_TYPE ThreadPool::PoolThread(void *Param)
{ … }


void ThreadPool::PoolThreadLoop()
{ … }


bool ThreadPool::GetQueuedTask(QueueEntry *Task)
{ … }


// Add task to queue. We assume that it is always called from main thread,
// it allows to avoid any locks here. We process collected tasks only
// when WaitDone is called.
void ThreadPool::AddTask(PTHREAD_PROC Proc,void *Data)
{ … }


// Start queued tasks and wait until all threads are inactive.
// We assume that it is always called from main thread, when pool threads
// are sleeping yet.
void ThreadPool::WaitDone()
{ … }
#endif // RAR_SMP