| Modifier and Type | Method and Description |
|---|---|
CloseableExecutorService |
AbstractAgentProxy.getExecutorService() |
| Constructor and Description |
|---|
AbstractAgentProxy(CloseableExecutorService executorService) |
| Constructor and Description |
|---|
ChannelAgentForwarding(CloseableExecutorService executor) |
| Modifier and Type | Field and Description |
|---|---|
protected CloseableExecutorService |
ChannelSession.pumperService |
| Modifier and Type | Method and Description |
|---|---|
CloseableExecutorService |
AbstractChannel.getExecutorService() |
| Constructor and Description |
|---|
AbstractChannel(String discriminator,
boolean client,
Collection<? extends RequestHandler<Channel>> handlers,
CloseableExecutorService executorService) |
| Modifier and Type | Method and Description |
|---|---|
CloseableExecutorService |
AbstractIoServiceFactory.getExecutorService() |
protected CloseableExecutorService |
AbstractIoServiceFactoryFactory.newExecutor() |
| Modifier and Type | Method and Description |
|---|---|
Factory<CloseableExecutorService> |
AbstractIoServiceFactoryFactory.getExecutorServiceFactory() |
| Modifier and Type | Method and Description |
|---|---|
void |
IoServiceFactoryFactory.setExecutorServiceFactory(Factory<CloseableExecutorService> factory) |
void |
AbstractIoServiceFactoryFactory.setExecutorServiceFactory(Factory<CloseableExecutorService> factory) |
| Constructor and Description |
|---|
AbstractIoServiceFactory(FactoryManager factoryManager,
CloseableExecutorService executorService) |
| Constructor and Description |
|---|
AbstractIoServiceFactoryFactory(Factory<CloseableExecutorService> factory) |
DefaultIoServiceFactoryFactory(Factory<CloseableExecutorService> factory) |
| Constructor and Description |
|---|
Nio2ServiceFactory(FactoryManager factoryManager,
CloseableExecutorService service,
CloseableExecutorService resumeTasks) |
| Constructor and Description |
|---|
Nio2ServiceFactoryFactory(Factory<CloseableExecutorService> executors) |
| Modifier and Type | Class and Description |
|---|---|
class |
NoCloseExecutor
Wraps an
ExecutorService as a CloseableExecutorService and avoids calling its shutdown
methods when the wrapper is shut down |
class |
SshThreadPoolExecutor |
| Modifier and Type | Method and Description |
|---|---|
Supplier<? extends CloseableExecutorService> |
ExecutorServiceProvider.getExecutorServiceProvider() |
| Modifier and Type | Method and Description |
|---|---|
static CloseableExecutorService |
ThreadUtils.newCachedThreadPoolIf(CloseableExecutorService executorService,
String poolName) |
static CloseableExecutorService |
ThreadUtils.newFixedThreadPoolIf(CloseableExecutorService executorService,
String poolName,
int nThreads) |
static CloseableExecutorService |
ThreadUtils.noClose(CloseableExecutorService executorService) |
static CloseableExecutorService |
ThreadUtils.protectExecutorServiceShutdown(CloseableExecutorService executorService,
boolean shutdownOnExit)
Wraps an
CloseableExecutorService in such a way as to "protect" it for calls to the
ExecutorService.shutdown() or ExecutorService.shutdownNow(). |
| Modifier and Type | Method and Description |
|---|---|
void |
ManagedExecutorServiceSupplier.setExecutorServiceProvider(Supplier<? extends CloseableExecutorService> provider) |
| Modifier and Type | Method and Description |
|---|---|
protected CloseableExecutorService |
ScpCommandFactory.resolveExecutorService(String command) |
| Modifier and Type | Method and Description |
|---|---|
Supplier<? extends CloseableExecutorService> |
ScpCommandFactory.getExecutorServiceProvider() |
| Modifier and Type | Method and Description |
|---|---|
void |
ScpCommandFactory.setExecutorServiceProvider(Supplier<? extends CloseableExecutorService> provider) |
ScpCommandFactory.Builder |
ScpCommandFactory.Builder.withExecutorServiceProvider(Supplier<? extends CloseableExecutorService> provider) |
| Constructor and Description |
|---|
ScpCommand(ChannelSession channelSession,
String command,
CloseableExecutorService executorService,
int sendSize,
int receiveSize,
ScpFileOpener fileOpener,
ScpTransferEventListener eventListener) |
ScpShell(ChannelSession channelSession,
CloseableExecutorService executorService,
int sendSize,
int receiveSize,
ScpFileOpener fileOpener,
ScpTransferEventListener eventListener) |
| Constructor and Description |
|---|
AbstractServerChannel(CloseableExecutorService executor) |
AbstractServerChannel(String discriminator,
Collection<? extends RequestHandler<Channel>> handlers,
CloseableExecutorService executor) |
| Modifier and Type | Field and Description |
|---|---|
protected CloseableExecutorService |
AbstractCommandSupport.executorService |
| Modifier and Type | Method and Description |
|---|---|
CloseableExecutorService |
AbstractCommandSupport.getExecutorService() |
| Constructor and Description |
|---|
AbstractCommandSupport(String command,
CloseableExecutorService executorService) |
AbstractFileSystemCommand(String command,
CloseableExecutorService executorService) |
| Modifier and Type | Method and Description |
|---|---|
CloseableExecutorService |
TcpipServerChannel.TcpipFactory.getExecutorService() |
| Constructor and Description |
|---|
TcpipServerChannel(TcpForwardingFilter.Type type,
CloseableExecutorService executor) |
| Modifier and Type | Field and Description |
|---|---|
protected CloseableExecutorService |
SftpSubsystem.executorService |
| Modifier and Type | Method and Description |
|---|---|
CloseableExecutorService |
SftpSubsystemFactory.getExecutorService() |
CloseableExecutorService |
SftpSubsystem.getExecutorService() |
| Modifier and Type | Method and Description |
|---|---|
Supplier<? extends CloseableExecutorService> |
SftpSubsystemFactory.getExecutorServiceProvider() |
| Modifier and Type | Method and Description |
|---|---|
void |
SftpSubsystemFactory.setExecutorServiceProvider(Supplier<? extends CloseableExecutorService> provider) |
SftpSubsystemFactory.Builder |
SftpSubsystemFactory.Builder.withExecutorServiceProvider(Supplier<? extends CloseableExecutorService> provider) |
Copyright © 2008–2024 The Apache Software Foundation. All rights reserved.