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

Modifier and Type	Field and Description
protected volatile ThreadPoolConfig	config
private volatile AbstractThreadPool	pool
private final Object	statelock

Access	Constructor and Description
protected	GrizzlyExecutorService(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.
public static GrizzlyExecutorService	createInstance() Returns: `GrizzlyExecutorService`
public static GrizzlyExecutorService	createInstance(ThreadPoolConfig `ThreadPoolConfig` cfg) Returns: `GrizzlyExecutorService`
public void	execute(Runnable r) Implements java.util.concurrent.Executor.execute. Executes the given command at some time in the future.
public ThreadPoolConfig	getConfiguration() Returns: config - `ThreadPoolConfig`
public MonitoringConfig<ThreadPoolProbe>	getMonitoringConfig() Implements org.glassfish.grizzly.monitoring.MonitoringAware.getMonitoringConfig. Return the object associated `MonitoringConfig`.
public boolean	isShutdown() Implements 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.
public GrizzlyExecutorService	Returns: returns `GrizzlyExecutorService` reconfigure(ThreadPoolConfig config) Sets the `ThreadPoolConfig`
protected final void	setImpl(ThreadPoolConfig cfg)
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.

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

config	back to summary
protected volatile ThreadPoolConfig config

pool	back to summary
private volatile AbstractThreadPool pool

statelock	back to summary
private final Object statelock

GrizzlyExecutorService	back to summary
protected GrizzlyExecutorService(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

createInstance	back to summary
public static GrizzlyExecutorService createInstance() Returns:GrizzlyExecutorService `GrizzlyExecutorService`

createInstance	back to summary
public static GrizzlyExecutorService createInstance(ThreadPoolConfig cfg) Parameters cfg:ThreadPoolConfig `ThreadPoolConfig` Returns:GrizzlyExecutorService `GrizzlyExecutorService`

execute back to summary

execute	back to summary
public void execute(Runnable r) 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 r)

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

getConfiguration	back to summary
public ThreadPoolConfig getConfiguration() Returns:ThreadPoolConfig config - `ThreadPoolConfig`

getMonitoringConfig back to summary

getMonitoringConfig	back to summary
public MonitoringConfig<ThreadPoolProbe> getMonitoringConfig() Implements org.glassfish.grizzly.monitoring.MonitoringAware.getMonitoringConfig. Doc from org.glassfish.grizzly.monitoring.MonitoringAware.getMonitoringConfig. Return the object associated `MonitoringConfig`. Annotations @Override

public MonitoringConfig<ThreadPoolProbe> getMonitoringConfig()

Implements org.glassfish.grizzly.monitoring.MonitoringAware.getMonitoringConfig.

Doc from org.glassfish.grizzly.monitoring.MonitoringAware.getMonitoringConfig.

Return the object associated MonitoringConfig.

Annotations

@Override

isShutdown back to summary

isShutdown	back to summary
public boolean isShutdown() Implements 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 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

reconfigure back to summary

reconfigure	back to summary
public GrizzlyExecutorService reconfigure(ThreadPoolConfig config) Sets the `ThreadPoolConfig` Returns:GrizzlyExecutorService returns `GrizzlyExecutorService`

public GrizzlyExecutorService reconfigure(ThreadPoolConfig config)

Sets the ThreadPoolConfig

Returns:GrizzlyExecutorService: returns GrizzlyExecutorService

setImpl	back to summary
protected final void setImpl(ThreadPoolConfig cfg)

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

public Class GrizzlyExecutorService

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail