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 |
AbstractIoServiceFactoryFactory.setExecutorServiceFactory(Factory<CloseableExecutorService> factory) |
void |
IoServiceFactoryFactory.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 |
SftpSubsystem.getExecutorService() |
CloseableExecutorService |
SftpSubsystemFactory.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.