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