libjava/java/util/concurrent/ThreadPoolExecutor.h

   1
   2 // DO NOT EDIT THIS FILE - it is machine generated -*- c++ -*-
   3
   4 #ifndef __java_util_concurrent_ThreadPoolExecutor__
   5 #define __java_util_concurrent_ThreadPoolExecutor__
   6
   7 #pragma interface
   8
   9 #include <java/util/concurrent/AbstractExecutorService.h>
  10 #include <gcj/array.h>
  11
  12
  13 class java::util::concurrent::ThreadPoolExecutor : public ::java::util::concurrent::AbstractExecutorService
  14 {
  15
  16 public: // actually package-private
  17   virtual void reject(::java::lang::Runnable *);
  18 private:
  19   ::java::lang::Thread * addThread(::java::lang::Runnable *);
  20   jboolean addIfUnderCorePoolSize(::java::lang::Runnable *);
  21   jint addIfUnderMaximumPoolSize(::java::lang::Runnable *);
  22 public: // actually package-private
  23   virtual ::java::lang::Runnable * getTask();
  24   virtual void interruptIdleWorkers();
  25   virtual void workerDone(::java::util::concurrent::ThreadPoolExecutor$Worker *);
  26 public:
  27   ThreadPoolExecutor(jint, jint, jlong, ::java::util::concurrent::TimeUnit *, ::java::util::concurrent::BlockingQueue *);
  28   ThreadPoolExecutor(jint, jint, jlong, ::java::util::concurrent::TimeUnit *, ::java::util::concurrent::BlockingQueue *, ::java::util::concurrent::ThreadFactory *);
  29   ThreadPoolExecutor(jint, jint, jlong, ::java::util::concurrent::TimeUnit *, ::java::util::concurrent::BlockingQueue *, ::java::util::concurrent::RejectedExecutionHandler *);
  30   ThreadPoolExecutor(jint, jint, jlong, ::java::util::concurrent::TimeUnit *, ::java::util::concurrent::BlockingQueue *, ::java::util::concurrent::ThreadFactory *, ::java::util::concurrent::RejectedExecutionHandler *);
  31   virtual void execute(::java::lang::Runnable *);
  32   virtual void shutdown();
  33   virtual ::java::util::List * shutdownNow();
  34   virtual jboolean isShutdown();
  35   virtual jboolean isTerminating();
  36   virtual jboolean isTerminated();
  37   virtual jboolean awaitTermination(jlong, ::java::util::concurrent::TimeUnit *);
  38 public: // actually protected
  39   virtual void finalize();
  40 public:
  41   virtual void setThreadFactory(::java::util::concurrent::ThreadFactory *);
  42   virtual ::java::util::concurrent::ThreadFactory * getThreadFactory();
  43   virtual void setRejectedExecutionHandler(::java::util::concurrent::RejectedExecutionHandler *);
  44   virtual ::java::util::concurrent::RejectedExecutionHandler * getRejectedExecutionHandler();
  45   virtual ::java::util::concurrent::BlockingQueue * getQueue();
  46   virtual jboolean remove(::java::lang::Runnable *);
  47   virtual void purge();
  48   virtual void setCorePoolSize(jint);
  49   virtual jint getCorePoolSize();
  50   virtual jboolean prestartCoreThread();
  51   virtual jint prestartAllCoreThreads();
  52   virtual jboolean allowsCoreThreadTimeOut();
  53   virtual void allowCoreThreadTimeOut(jboolean);
  54   virtual void setMaximumPoolSize(jint);
  55   virtual jint getMaximumPoolSize();
  56   virtual void setKeepAliveTime(jlong, ::java::util::concurrent::TimeUnit *);
  57   virtual jlong getKeepAliveTime(::java::util::concurrent::TimeUnit *);
  58   virtual jint getPoolSize();
  59   virtual jint getActiveCount();
  60   virtual jint getLargestPoolSize();
  61   virtual jlong getTaskCount();
  62   virtual jlong getCompletedTaskCount();
  63 public: // actually protected
  64   virtual void beforeExecute(::java::lang::Thread *, ::java::lang::Runnable *);
  65   virtual void afterExecute(::java::lang::Runnable *, ::java::lang::Throwable *);
  66   virtual void terminated();
  67 private:
  68   static JArray< ::java::lang::Runnable * > * EMPTY_RUNNABLE_ARRAY;
  69   static ::java::lang::RuntimePermission * shutdownPerm;
  70   ::java::util::concurrent::BlockingQueue * __attribute__((aligned(__alignof__( ::java::util::concurrent::AbstractExecutorService)))) workQueue;
  71   ::java::util::concurrent::locks::ReentrantLock * mainLock;
  72   ::java::util::concurrent::locks::Condition * termination;
  73   ::java::util::HashSet * workers;
  74   volatile jlong keepAliveTime;
  75   volatile jboolean allowCoreThreadTimeOut__;
  76   volatile jint corePoolSize;
  77   volatile jint maximumPoolSize;
  78   volatile jint poolSize;
  79 public: // actually package-private
  80   volatile jint runState;
  81   static const jint RUNNING = 0;
  82   static const jint SHUTDOWN = 1;
  83   static const jint STOP = 2;
  84   static const jint TERMINATED = 3;
  85 private:
  86   volatile ::java::util::concurrent::RejectedExecutionHandler * handler;
  87   volatile ::java::util::concurrent::ThreadFactory * threadFactory;
  88   jint largestPoolSize;
  89   jlong completedTaskCount;
  90   static ::java::util::concurrent::RejectedExecutionHandler * defaultHandler;
  91 public: // actually package-private
  92   static jboolean $assertionsDisabled;
  93 public:
  94   static ::java::lang::Class class$;
  95 };
  96
  97 #endif // __java_util_concurrent_ThreadPoolExecutor__