/home/jeroen/FOX/fox/fox-1.7.33/include/FXThreadPool.h

/********************************************************************************
*                                                                               *
*                             T h r e a d   P o o l                             *
*                                                                               *
*********************************************************************************
* Copyright (C) 2006,2012 by Jeroen van der Zijp.   All Rights Reserved.        *
*********************************************************************************
* This library is free software; you can redistribute it and/or modify          *
* it under the terms of the GNU Lesser General Public License as published by   *
* the Free Software Foundation; either version 3 of the License, or             *
* (at your option) any later version.                                           *
*                                                                               *
* This library is distributed in the hope that it will be useful,               *
* but WITHOUT ANY WARRANTY; without even the implied warranty of                *
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the                 *
* GNU Lesser General Public License for more details.                           *
*                                                                               *
* You should have received a copy of the GNU Lesser General Public License      *
* along with this program.  If not, see <http://www.gnu.org/licenses/>          *
********************************************************************************/
#ifndef FXTHREADPOOL_H
#define FXTHREADPOOL_H

#ifndef FXRUNNABLE_H
#include "FXRunnable.h"
#endif

namespace FX {


class FXWorker;


typedef FXPtrQueueOf<FXRunnable> FXJobQueue;


class FXAPI FXThreadPool : public FXRunnable {
private:
  FXJobQueue      queue;        // Job queue
  FXMutex         mutex;        // Pool mutex
  FXCondition     pcond;        // Producer condition
  FXCondition     ccond;        // Consumer condition
  FXCondition     wcond;        // Wait condition
  FXTime          expire;       // Quit if no job within this time
  volatile FXuint maximum;      // Maximum number of workers
  volatile FXuint minimum;      // Minimum number of workers
  volatile FXuint started;      // Number of workers started
  volatile FXuint stopped;      // Number of workers stopped
  volatile FXuint pwaiting;     // Producers waiting
  volatile FXuint cwaiting;     // Consumers waiting
  volatile FXuint watching;     // Threads watching completion
  volatile FXbool runs;         // Thread pool is running
private:
  FXWorker* startWorker();
private:
  FXThreadPool(const FXThreadPool&);
  FXThreadPool &operator=(const FXThreadPool&);
public:

  FXThreadPool(FXuint sz=256);

  FXbool setSize(FXuint sz);

  FXuint getSize() const;

  FXbool active() const;

  FXuint getWaitingThreads() const;

  FXuint getRunningThreads() const;

  void setMinimumThreads(FXuint n);

  FXuint getMinimumThreads() const;

  void setMaximumThreads(FXuint n);

  FXuint getMaximumThreads() const;

  void setExpiration(FXTime ns=forever);

  FXTime getExpiration() const;

  FXuint start(FXuint min=1,FXuint max=32,FXuint cnt=0);

  FXbool wait();

  void stop();

  FXbool execute(FXRunnable *job,FXTime blocking=forever);

  virtual FXint run();

  virtual ~FXThreadPool();
  };

}

#endif