gobblin.util.concurrent

Class TaskSchedulerFactory

java.lang.Object

gobblin.util.concurrent.TaskSchedulerFactory

public class TaskSchedulerFactory
extends Object

A factory which can be used to get an instance of TaskScheduler.

Method Summary

Modifier and Type	Method and Description
static <K,T extends ScheduledTask<K>> TaskScheduler<K,T>	get(String type, Optional<String> name) Gets an instance of the TaskScheduler with the specified type and ensures that it is started.
static <K,T extends ScheduledTask<K>> TaskScheduler<K,T>	get(TaskSchedulerType type, Optional<String> name) Gets an instance of the TaskScheduler with the specified type and ensures that it is started.

Methods inherited from class java.lang.Object

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

Method Detail

get

public static <K,T extends ScheduledTask<K>> TaskScheduler<K,T> get(String type,
                                                                    Optional<String> name)

Gets an instance of the TaskScheduler with the specified type and ensures that it is started. If the type is unknown an instance of the default TaskScheduler will be returned.

Type Parameters:

K - the type of the key for the ScheduledTask

T - the type of the ScheduledTask

Parameters:

type - the type of the TaskScheduler

name - the name associated threads created by the TaskScheduler

Returns:

an instance of TaskScheduler

get

public static <K,T extends ScheduledTask<K>> TaskScheduler<K,T> get(TaskSchedulerType type,
                                                                    Optional<String> name)

Gets an instance of the TaskScheduler with the specified type and ensures that it is started. If the type is unknown an instance of the default TaskScheduler will be returned.

Type Parameters:

K - the type of the key for the ScheduledTask

T - the type of the ScheduledTask

Parameters:

type - the type of the TaskScheduler

name - the name associated threads created by the TaskScheduler

Returns:

an instance of TaskScheduler