51 lines
1.1 KiB
C
51 lines
1.1 KiB
C
|
/*
|
||
|
|
* Copyright 2012 Google Inc.
|
||
|
|
*
|
||
|
|
* Use of this source code is governed by a BSD-style license that can be
|
||
|
|
* found in the LICENSE file.
|
||
|
|
*/
|
||
|
|
|
||
|
|
#ifndef SkThreadPool_DEFINED
|
||
|
|
#define SkThreadPool_DEFINED
|
||
|
|
|
||
|
|
#include "SkCondVar.h"
|
||
|
|
#include "SkTDArray.h"
|
||
|
|
#include "SkTDLinkedList.h"
|
||
|
|
|
||
|
|
class SkRunnable;
|
||
|
|
class SkThread;
|
||
|
|
|
||
|
|
class SkThreadPool {
|
||
|
|
|
||
|
|
public:
|
||
|
|
/**
|
||
|
|
* Create a threadpool with exactly count (>=0) threads.
|
||
|
|
*/
|
||
|
|
explicit SkThreadPool(int count);
|
||
|
|
~SkThreadPool();
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Queues up an SkRunnable to run when a thread is available, or immediately if
|
||
|
|
* count is 0. NULL is a safe no-op. Does not take ownership.
|
||
|
|
*/
|
||
|
|
void add(SkRunnable*);
|
||
|
|
|
||
|
|
private:
|
||
|
|
struct LinkedRunnable {
|
||
|
|
// Unowned pointer.
|
||
|
|
SkRunnable* fRunnable;
|
||
|
|
|
||
|
|
private:
|
||
|
|
SK_DEFINE_DLINKEDLIST_INTERFACE(LinkedRunnable)
|
||
|
|
};
|
||
|
|
|
||
|
|
SkTDLinkedList<LinkedRunnable> fQueue;
|
||
|
|
SkCondVar fReady;
|
||
|
|
SkTDArray<SkThread*> fThreads;
|
||
|
|
bool fDone;
|
||
|
|
|
||
|
|
static void Loop(void*); // Static because we pass in this.
|
||
|
|
};
|
||
|
|
|
||
|
|
#endif
|