| |
| // 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__ |