ThreadPoolExecutor.h 4.4 KB

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