Grizzly NIO 5.0.2 · org.glassfish.grizzly.threadpool.VirtualThreadExecutorService

Modifier and Type	Field and Description
private final ExecutorService	internalExecutorService
private static final Logger	logger
protected final DefaultMonitoringConfig<ThreadPoolProbe>	monitoringConfig ThreadPool probes
private final ThreadPoolConfig	originalConfig
private final Semaphore	poolSemaphore
private final Semaphore	queueSemaphore
private final AtomicInteger	queueSize
private final AtomicInteger	threadsCount

Access	Constructor and Description
protected	VirtualThreadExecutorService(ThreadPoolConfig config)

Method Summary

Modifier and Type	Method and Description
public boolean	awaitTermination(long timeout, TimeUnit unit) Implements java.util.concurrent.ExecutorService.awaitTermination. Blocks until all tasks have completed execution after a shutdown request, or the timeout occurs, or the current thread is interrupted, whichever happens first.
private void	beforeExecute(final AbstractThreadPool.Worker worker, final Thread t, final Runnable r)
public static VirtualThreadExecutorService	createInstance()
public static VirtualThreadExecutorService	createInstance(ThreadPoolConfig cfg)
pack-priv Object	createJmxManagementObject()
public void	execute(Runnable task) Implements java.util.concurrent.Executor.execute. Executes the given command at some time in the future.
public ThreadPoolConfig	getConfig() Implements org.glassfish.grizzly.threadpool.ThreadPoolInfo.getConfig.
public DefaultMonitoringConfig<ThreadPoolProbe>	getMonitoringConfig() Implements org.glassfish.grizzly.threadpool.ThreadPoolInfo.getMonitoringConfig.
public int	getQueueSize() Implements org.glassfish.grizzly.threadpool.ThreadPoolInfo.getQueueSize.
public int	getSize() Implements org.glassfish.grizzly.threadpool.ThreadPoolInfo.getSize.
private ThreadFactory	getThreadFactory(ThreadPoolConfig threadPoolConfig)
public boolean	isShutdown() Implements org.glassfish.grizzly.threadpool.ThreadPoolInfo.isShutdown, java.util.concurrent.ExecutorService.isShutdown. Returns `true` if this executor has been shut down.
public boolean	isTerminated() Implements java.util.concurrent.ExecutorService.isTerminated. Returns `true` if all tasks have completed following shut down.
protected void	onMaxNumberOfThreadsReached() Method is called by `AbstractThreadPool`, when maximum number of worker threads is reached and task will need to wait in task queue, until one of the threads will be able to process it.
protected void	onTaskCancelled(Runnable task) Method is called by a thread pool each time a dequeued task has been canceled instead of being processed.
protected void	onTaskCompletedEvent(Runnable the unit of work that has completed processing task) This method will be invoked when a the specified `Runnable` has completed execution.
protected void	onTaskDequeued(Runnable task) Method is called by a thread pool each time a task has been dequeued from a task queue.
protected void	onTaskQueued(Runnable task) Method is called by a thread pool each time new task has been queued to a task queue.
protected void	onWorkerExit(Thread thread) Method is called by `Worker`, when it's completing `Worker#run()` method execution, which in most cases means, that ThreadPool's thread will be released.
protected void	onWorkerStarted(Thread thread) Method is called by `Worker`, when it's starting `Worker#run()` method execution, which means, that ThreadPool's thread is getting active and ready to process tasks.
public void	shutdown() Implements java.util.concurrent.ExecutorService.shutdown. Initiates an orderly shutdown in which previously submitted tasks are executed, but no new tasks will be accepted.
public List<Runnable>	shutdownNow() Implements java.util.concurrent.ExecutorService.shutdownNow. Attempts to stop all actively executing tasks, halts the processing of waiting tasks, and returns a list of the tasks that were awaiting execution.
public void	uncaughtException(Thread thread, Throwable throwable) Implements java.lang.Thread.UncaughtExceptionHandler.uncaughtException. Method invoked when the given thread terminates due to the given uncaught exception.

Inherited from java.util.concurrent.AbstractExecutorService:: invokeAll invokeAll invokeAny invokeAny newTaskFor newTaskFor submit submit submit

internalExecutorService	back to summary
private final ExecutorService internalExecutorService

logger	back to summary
private static final Logger logger

monitoringConfig	back to summary
protected final DefaultMonitoringConfig<ThreadPoolProbe> monitoringConfig ThreadPool probes

originalConfig	back to summary
private final ThreadPoolConfig originalConfig

poolSemaphore	back to summary
private final Semaphore poolSemaphore

queueSemaphore	back to summary
private final Semaphore queueSemaphore

queueSize	back to summary
private final AtomicInteger queueSize

threadsCount	back to summary
private final AtomicInteger threadsCount

VirtualThreadExecutorService	back to summary
protected VirtualThreadExecutorService(ThreadPoolConfig config)

Method Detail

awaitTermination	back to summary
public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException Implements java.util.concurrent.ExecutorService.awaitTermination. Doc from java.util.concurrent.ExecutorService.awaitTermination. Blocks until all tasks have completed execution after a shutdown request, or the timeout occurs, or the current thread is interrupted, whichever happens first. Annotations @Override Exceptions InterruptedException: if interrupted while waiting

awaitTermination

back to summary

public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException

Implements java.util.concurrent.ExecutorService.awaitTermination.

Doc from java.util.concurrent.ExecutorService.awaitTermination.

Blocks until all tasks have completed execution after a shutdown request, or the timeout occurs, or the current thread is interrupted, whichever happens first.

Annotations

@Override

Exceptions

InterruptedException:: if interrupted while waiting

beforeExecute	back to summary
private void beforeExecute(final AbstractThreadPool.Worker worker, final Thread t, final Runnable r)

createInstance	back to summary
public static VirtualThreadExecutorService createInstance()

createInstance	back to summary
public static VirtualThreadExecutorService createInstance(ThreadPoolConfig cfg)

createJmxManagementObject	back to summary
pack-priv Object createJmxManagementObject()

execute back to summary

execute	back to summary
public void execute(Runnable task) Implements java.util.concurrent.Executor.execute. Doc from java.util.concurrent.Executor.execute. Executes the given command at some time in the future. The command may execute in a new thread, in a pooled thread, or in the calling thread, at the discretion of the `Executor` implementation. Annotations @Override

public void execute(Runnable task)

Implements java.util.concurrent.Executor.execute.

Doc from java.util.concurrent.Executor.execute.

Executes the given command at some time in the future. The command may execute in a new thread, in a pooled thread, or in the calling thread, at the discretion of the Executor implementation.

Annotations

@Override

getConfig	back to summary
public ThreadPoolConfig getConfig() Implements org.glassfish.grizzly.threadpool.ThreadPoolInfo.getConfig. Annotations @Override

getConfig

back to summary

public ThreadPoolConfig getConfig()

Implements org.glassfish.grizzly.threadpool.ThreadPoolInfo.getConfig.

Annotations

@Override

getMonitoringConfig	back to summary
public DefaultMonitoringConfig<ThreadPoolProbe> getMonitoringConfig() Implements org.glassfish.grizzly.threadpool.ThreadPoolInfo.getMonitoringConfig. Annotations @Override

getMonitoringConfig

back to summary

public DefaultMonitoringConfig<ThreadPoolProbe> getMonitoringConfig()

Implements org.glassfish.grizzly.threadpool.ThreadPoolInfo.getMonitoringConfig.

Annotations

@Override

getQueueSize	back to summary
public int getQueueSize() Implements org.glassfish.grizzly.threadpool.ThreadPoolInfo.getQueueSize. Annotations @Override

getQueueSize

back to summary

public int getQueueSize()

Implements org.glassfish.grizzly.threadpool.ThreadPoolInfo.getQueueSize.

Annotations

@Override

getSize	back to summary
public int getSize() Implements org.glassfish.grizzly.threadpool.ThreadPoolInfo.getSize. Annotations @Override

getSize

back to summary

public int getSize()

Implements org.glassfish.grizzly.threadpool.ThreadPoolInfo.getSize.

Annotations

@Override

getThreadFactory	back to summary
private ThreadFactory getThreadFactory(ThreadPoolConfig threadPoolConfig)

isShutdown back to summary

isShutdown	back to summary
public boolean isShutdown() Implements org.glassfish.grizzly.threadpool.ThreadPoolInfo.isShutdown, java.util.concurrent.ExecutorService.isShutdown. Doc from java.util.concurrent.ExecutorService.isShutdown. Returns `true` if this executor has been shut down. Annotations @Override

public boolean isShutdown()

Implements org.glassfish.grizzly.threadpool.ThreadPoolInfo.isShutdown, java.util.concurrent.ExecutorService.isShutdown.

Doc from java.util.concurrent.ExecutorService.isShutdown.

Returns true if this executor has been shut down.

Annotations

@Override

isTerminated back to summary

isTerminated	back to summary
public boolean isTerminated() Implements java.util.concurrent.ExecutorService.isTerminated. Doc from java.util.concurrent.ExecutorService.isTerminated. Returns `true` if all tasks have completed following shut down. Note that `isTerminated` is never `true` unless either `shutdown` or `shutdownNow` was called first. Annotations @Override

public boolean isTerminated()

Implements java.util.concurrent.ExecutorService.isTerminated.

Doc from java.util.concurrent.ExecutorService.isTerminated.

Returns true if all tasks have completed following shut down. Note that isTerminated is never true unless either shutdown or shutdownNow was called first.

Annotations

@Override

onMaxNumberOfThreadsReached	back to summary
protected void onMaxNumberOfThreadsReached() Method is called by `AbstractThreadPool`, when maximum number of worker threads is reached and task will need to wait in task queue, until one of the threads will be able to process it.

onTaskCancelled	back to summary
protected void onTaskCancelled(Runnable task) Method is called by a thread pool each time a dequeued task has been canceled instead of being processed.

onTaskCompletedEvent back to summary

onTaskCompletedEvent	back to summary
protected void onTaskCompletedEvent(Runnable task) This method will be invoked when a the specified `Runnable` has completed execution. Parameters task:Runnable the unit of work that has completed processing

protected void onTaskCompletedEvent(Runnable task)

This method will be invoked when a the specified Runnable has completed execution.

Parameters

task:Runnable: the unit of work that has completed processing

onTaskDequeued	back to summary
protected void onTaskDequeued(Runnable task) Method is called by a thread pool each time a task has been dequeued from a task queue.

onTaskQueued	back to summary
protected void onTaskQueued(Runnable task) Method is called by a thread pool each time new task has been queued to a task queue.

onWorkerExit	back to summary
protected void onWorkerExit(Thread thread) Method is called by `Worker`, when it's completing `Worker#run()` method execution, which in most cases means, that ThreadPool's thread will be released. This method is called from `Worker`'s thread.

onWorkerStarted	back to summary
protected void onWorkerStarted(Thread thread) Method is called by `Worker`, when it's starting `Worker#run()` method execution, which means, that ThreadPool's thread is getting active and ready to process tasks. This method is called from `Worker`'s thread.

shutdown back to summary

shutdown	back to summary
public void shutdown() Implements java.util.concurrent.ExecutorService.shutdown. Doc from java.util.concurrent.ExecutorService.shutdown. Initiates an orderly shutdown in which previously submitted tasks are executed, but no new tasks will be accepted. Invocation has no additional effect if already shut down. This method does not wait for previously submitted tasks to complete execution. Use `awaitTermination` to do that. Annotations @Override

public void shutdown()

Implements java.util.concurrent.ExecutorService.shutdown.

Doc from java.util.concurrent.ExecutorService.shutdown.

Initiates an orderly shutdown in which previously submitted tasks are executed, but no new tasks will be accepted. Invocation has no additional effect if already shut down.

This method does not wait for previously submitted tasks to complete execution. Use awaitTermination to do that.

Annotations

@Override

shutdownNow back to summary

shutdownNow	back to summary
public List<Runnable> shutdownNow() Implements java.util.concurrent.ExecutorService.shutdownNow. Doc from java.util.concurrent.ExecutorService.shutdownNow. Attempts to stop all actively executing tasks, halts the processing of waiting tasks, and returns a list of the tasks that were awaiting execution. This method does not wait for actively executing tasks to terminate. Use `awaitTermination` to do that. There are no guarantees beyond best-effort attempts to stop processing actively executing tasks. For example, typical implementations will cancel via `Thread#interrupt`, so any task that fails to respond to interrupts may never terminate. Annotations @Override

public List<Runnable> shutdownNow()

Implements java.util.concurrent.ExecutorService.shutdownNow.

Doc from java.util.concurrent.ExecutorService.shutdownNow.

Attempts to stop all actively executing tasks, halts the processing of waiting tasks, and returns a list of the tasks that were awaiting execution.

This method does not wait for actively executing tasks to terminate. Use awaitTermination to do that.

There are no guarantees beyond best-effort attempts to stop processing actively executing tasks. For example, typical implementations will cancel via Thread#interrupt, so any task that fails to respond to interrupts may never terminate.

Annotations

@Override

uncaughtException	back to summary
public void uncaughtException(Thread thread, Throwable throwable) Implements java.lang.Thread.UncaughtExceptionHandler.uncaughtException. Doc from java.lang.Thread.UncaughtExceptionHandler.uncaughtException. Method invoked when the given thread terminates due to the given uncaught exception. Any exception thrown by this method will be ignored by the Java Virtual Machine. Annotations @Override

uncaughtException

back to summary

public void uncaughtException(Thread thread, Throwable throwable)

Implements java.lang.Thread.UncaughtExceptionHandler.uncaughtException.

Doc from java.lang.Thread.UncaughtExceptionHandler.uncaughtException.

Method invoked when the given thread terminates due to the given uncaught exception.

Any exception thrown by this method will be ignored by the Java Virtual Machine.

Annotations

@Override

public Class VirtualThreadExecutorService

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail