
// DO NOT EDIT THIS FILE - it is machine generated -*- c++ -*-

#ifndef __java_util_concurrent_ThreadPoolExecutor__
#define __java_util_concurrent_ThreadPoolExecutor__

#pragma interface

#include <java/util/concurrent/AbstractExecutorService.h>
#include <gcj/array.h>


class java::util::concurrent::ThreadPoolExecutor : public ::java::util::concurrent::AbstractExecutorService
{

public: // actually package-private
  virtual void reject(::java::lang::Runnable *);
private:
  ::java::lang::Thread * addThread(::java::lang::Runnable *);
  jboolean addIfUnderCorePoolSize(::java::lang::Runnable *);
  jint addIfUnderMaximumPoolSize(::java::lang::Runnable *);
public: // actually package-private
  virtual ::java::lang::Runnable * getTask();
  virtual void interruptIdleWorkers();
  virtual void workerDone(::java::util::concurrent::ThreadPoolExecutor$Worker *);
public:
  ThreadPoolExecutor(jint, jint, jlong, ::java::util::concurrent::TimeUnit *, ::java::util::concurrent::BlockingQueue *);
  ThreadPoolExecutor(jint, jint, jlong, ::java::util::concurrent::TimeUnit *, ::java::util::concurrent::BlockingQueue *, ::java::util::concurrent::ThreadFactory *);
  ThreadPoolExecutor(jint, jint, jlong, ::java::util::concurrent::TimeUnit *, ::java::util::concurrent::BlockingQueue *, ::java::util::concurrent::RejectedExecutionHandler *);
  ThreadPoolExecutor(jint, jint, jlong, ::java::util::concurrent::TimeUnit *, ::java::util::concurrent::BlockingQueue *, ::java::util::concurrent::ThreadFactory *, ::java::util::concurrent::RejectedExecutionHandler *);
  virtual void execute(::java::lang::Runnable *);
  virtual void shutdown();
  virtual ::java::util::List * shutdownNow();
  virtual jboolean isShutdown();
  virtual jboolean isTerminating();
  virtual jboolean isTerminated();
  virtual jboolean awaitTermination(jlong, ::java::util::concurrent::TimeUnit *);
public: // actually protected
  virtual void finalize();
public:
  virtual void setThreadFactory(::java::util::concurrent::ThreadFactory *);
  virtual ::java::util::concurrent::ThreadFactory * getThreadFactory();
  virtual void setRejectedExecutionHandler(::java::util::concurrent::RejectedExecutionHandler *);
  virtual ::java::util::concurrent::RejectedExecutionHandler * getRejectedExecutionHandler();
  virtual ::java::util::concurrent::BlockingQueue * getQueue();
  virtual jboolean remove(::java::lang::Runnable *);
  virtual void purge();
  virtual void setCorePoolSize(jint);
  virtual jint getCorePoolSize();
  virtual jboolean prestartCoreThread();
  virtual jint prestartAllCoreThreads();
  virtual jboolean allowsCoreThreadTimeOut();
  virtual void allowCoreThreadTimeOut(jboolean);
  virtual void setMaximumPoolSize(jint);
  virtual jint getMaximumPoolSize();
  virtual void setKeepAliveTime(jlong, ::java::util::concurrent::TimeUnit *);
  virtual jlong getKeepAliveTime(::java::util::concurrent::TimeUnit *);
  virtual jint getPoolSize();
  virtual jint getActiveCount();
  virtual jint getLargestPoolSize();
  virtual jlong getTaskCount();
  virtual jlong getCompletedTaskCount();
public: // actually protected
  virtual void beforeExecute(::java::lang::Thread *, ::java::lang::Runnable *);
  virtual void afterExecute(::java::lang::Runnable *, ::java::lang::Throwable *);
  virtual void terminated();
private:
  static JArray< ::java::lang::Runnable * > * EMPTY_RUNNABLE_ARRAY;
  static ::java::lang::RuntimePermission * shutdownPerm;
  ::java::util::concurrent::BlockingQueue * __attribute__((aligned(__alignof__( ::java::util::concurrent::AbstractExecutorService)))) workQueue;
  ::java::util::concurrent::locks::ReentrantLock * mainLock;
  ::java::util::concurrent::locks::Condition * termination;
  ::java::util::HashSet * workers;
  jlong volatile keepAliveTime;
  jboolean volatile allowCoreThreadTimeOut__;
  jint volatile corePoolSize;
  jint volatile maximumPoolSize;
  jint volatile poolSize;
public: // actually package-private
  jint volatile runState;
  static const jint RUNNING = 0;
  static const jint SHUTDOWN = 1;
  static const jint STOP = 2;
  static const jint TERMINATED = 3;
private:
  ::java::util::concurrent::RejectedExecutionHandler * volatile handler;
  ::java::util::concurrent::ThreadFactory * volatile threadFactory;
  jint largestPoolSize;
  jlong completedTaskCount;
  static ::java::util::concurrent::RejectedExecutionHandler * defaultHandler;
public: // actually package-private
  static jboolean $assertionsDisabled;
public:
  static ::java::lang::Class class$;
};

#endif // __java_util_concurrent_ThreadPoolExecutor__