com.netflix.genie.web.configs

Class TaskConfig

java.lang.Object

com.netflix.genie.web.configs.TaskConfig

@Configuration
 @EnableScheduling
public class TaskConfig
extends java.lang.Object

Configuration of beans for asynchronous tasks within Genie.

Since:

3.0.0

Constructor Summary

Constructors

Constructor and Description
TaskConfig()

Method Summary

Modifier and Type	Method and Description
org.springframework.core.task.AsyncTaskExecutor	genieAsyncTaskExecutor(int poolSize) Get a task executor for executing tasks asynchronously that don't need to be scheduled at a recurring rate.
org.springframework.core.task.SyncTaskExecutor	genieSyncTaskExecutor() Synchronous task executor.
org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler	genieTaskScheduler(int poolSize) Get a task scheduler.
org.apache.commons.exec.Executor	processExecutor() Get an Executor to use for executing processes from tasks.

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskConfig

public TaskConfig()

Method Detail

processExecutor

@Bean
public org.apache.commons.exec.Executor processExecutor()

Get an Executor to use for executing processes from tasks.

Returns:

The executor to use

genieTaskScheduler

@Bean
public org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler genieTaskScheduler(@Value(value="${genie.tasks.scheduler.pool.size:1}")
                                                                                                  int poolSize)

Get a task scheduler.

Parameters:

poolSize - The initial size of the thread pool that should be allocated

Returns:

The task scheduler

genieAsyncTaskExecutor

@Bean
public org.springframework.core.task.AsyncTaskExecutor genieAsyncTaskExecutor(@Value(value="${genie.tasks.executor.pool.size:1}")
                                                                                    int poolSize)

Get a task executor for executing tasks asynchronously that don't need to be scheduled at a recurring rate.

Parameters:

poolSize - The number of threads desired for this system. Likely best to do one more than number of CPUs

Returns:

The task executor the system to use

genieSyncTaskExecutor

@Bean
public org.springframework.core.task.SyncTaskExecutor genieSyncTaskExecutor()

Synchronous task executor.

Returns:

The synchronous task executor to use