Package ch.tocco.nice2.persist.core.impl.exec

Class CommandExecutorImpl

java.lang.Object

ch.tocco.nice2.persist.core.impl.exec.CommandExecutorImpl

All Implemented Interfaces:

CommandExecutor

@Component
public class CommandExecutorImpl
extends Object
implements CommandExecutor

Constructor Summary

Constructors

Constructor	Description
CommandExecutorImpl(org.slf4j.Logger log, Context currentContext, ContextManager contextManager, PersistenceService persistenceService, QueryBuilderFactory queryBuilderFactory, ThreadHandlerManager threadHandlerManager, L10N l10N)

Method Summary

Modifier and Type	Method	Description
CommandService	createForThreadPool(ExecutorService executorService)	Creates a new CommandService using the specified thread pool.
CommandService	getCommandService()	Returns the default CommandService for asynchronously executing persist tasks.
void	initializeService()
<A, T, E extends Exception> Optional<T>	perform(Mode<E> mode, PersistTask<A,T> task, A arg)	Performs the given task immediately using the thread of the caller.
<A, T, E extends Exception> Optional<T>	performInterruptible(Mode<E> mode, PersistTask<A,T> task, A arg)	Deprecated.
<A, T, E extends Exception> Optional<T>	performUninterruptly(Mode<E> mode, PersistTask<A,T> task, A arg)	Deprecated.
void	registryDidShutdown()
void	setDefaultThreadCount(int defaultThreadCount)
void	setListeners(List<CommandServiceListener> listeners)
void	setModes(List<ModeWrapper> modes)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

CommandExecutorImpl

public CommandExecutorImpl(org.slf4j.Logger log,
 Context currentContext,
 ContextManager contextManager,
 @Lazy
 PersistenceService persistenceService,
 QueryBuilderFactory queryBuilderFactory,
 ThreadHandlerManager threadHandlerManager,
 L10N l10N)

Method Details

registryDidShutdown

@PreDestroy
public void registryDidShutdown()

setListeners

@Autowired
public void setListeners(List<CommandServiceListener> listeners)

setDefaultThreadCount

@Value("${persist.tasks.commandservice.maxThreads}")
public void setDefaultThreadCount(int defaultThreadCount)

initializeService

@PostConstruct
public void initializeService()

setModes

@Autowired
public void setModes(List<ModeWrapper> modes)

perform

public <A,
T,
E extends Exception> Optional<T> perform(Mode<E> mode,
 PersistTask<A,T> task,
 @Nullable
 A arg)
                                                throws E

Description copied from interface: CommandExecutor

Performs the given task immediately using the thread of the caller. The supplied mode controls the execution of the task.

Specified by:

perform in interface CommandExecutor

Type Parameters:

T - type of the result of the task

E - the expected exception

Parameters:

mode - the mode controls the execution

task - the task to execute

Throws:

E

performUninterruptly

@Deprecated
public <A,
T,
E extends Exception> Optional<T> performUninterruptly(Mode<E> mode,
 PersistTask<A,T> task,
 @Nullable
 A arg)
                                                             throws E

Deprecated.

Description copied from interface: CommandExecutor

Like CommandExecutor.perform(Mode, PersistTask, Object) but retries on interrupt until the task is completed. It re-interrupts the thread if necessary.

Specified by:

performUninterruptly in interface CommandExecutor

Throws:

E

performInterruptible

@Deprecated
public <A,
T,
E extends Exception> Optional<T> performInterruptible(Mode<E> mode,
 PersistTask<A,T> task,
 @Nullable
 A arg)
                                                             throws E

Deprecated.

Description copied from interface: CommandExecutor

Like CommandExecutor.perform(Mode, PersistTask, Object) but will stop on interrupt and wrap the InterruptedException into the exception specified by the given mode.

Specified by:

performInterruptible in interface CommandExecutor

Throws:

E

createForThreadPool

public CommandService createForThreadPool(ExecutorService executorService)

Description copied from interface: CommandExecutor

Creates a new CommandService using the specified thread pool. The returned service is thread safe and can be used as a singleton like any other service.

Specified by:

createForThreadPool in interface CommandExecutor

getCommandService

public CommandService getCommandService()

Description copied from interface: CommandExecutor

Returns the default CommandService for asynchronously executing persist tasks.

Note, the configuration of the thread pool of the service is left to the implementation. It can be assumed that there are more than one thread executing the persist tasks. Thus, if ordering is important, you would need to create a single-threaded command service using CommandExecutor.createForThreadPool(ExecutorService).

Specified by:

getCommandService in interface CommandExecutor