Package ubic.gemma.core.job

Class TaskRunningServiceImpl

java.lang.Object

ubic.gemma.core.job.TaskRunningServiceImpl

All Implemented Interfaces:

io.micrometer.core.instrument.binder.MeterBinder, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean, TaskRunningService

@Component("taskRunningService")
@ParametersAreNonnullByDefault
public class TaskRunningServiceImpl
extends Object
implements TaskRunningService, org.springframework.beans.factory.InitializingBean, org.springframework.beans.factory.DisposableBean

Handles the execution of tasks in threads that can be checked by clients later.

Author:

pavlidis

Constructor Summary

Constructors

Constructor	Description
TaskRunningServiceImpl()

Method Summary

Modifier and Type	Method	Description
void	afterPropertiesSet()
void	bindTo(io.micrometer.core.instrument.MeterRegistry meterRegistry)
void	destroy()
SubmittedTask	getSubmittedTask(String taskId)
Collection<SubmittedTask>	getSubmittedTasks()
<T extends Task<?>> String	submitTask(T task)
<C extends TaskCommand> String	submitTaskCommand(C taskCommand)	We check if there are listeners on task submission queue to decide if remote tasks can be served.

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskRunningServiceImpl

public TaskRunningServiceImpl()

Method Detail

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

Throws:

Exception

destroy

public void destroy()
             throws Exception

Specified by:

destroy in interface org.springframework.beans.factory.DisposableBean

Throws:

Exception

getSubmittedTask

public SubmittedTask getSubmittedTask(String taskId)

Specified by:

getSubmittedTask in interface TaskRunningService

getSubmittedTasks

public Collection<SubmittedTask> getSubmittedTasks()

Specified by:

getSubmittedTasks in interface TaskRunningService

Returns:

the submittedTasks

submitTask

public <T extends Task<?>> String submitTask(T task)

Specified by:

submitTask in interface TaskRunningService

submitTaskCommand

public <C extends TaskCommand> String submitTaskCommand(C taskCommand)

We check if there are listeners on task submission queue to decide if remote tasks can be served.

Specified by:

submitTaskCommand in interface TaskRunningService

Type Parameters:

C - task command implementation

Parameters:

taskCommand - The command to run. The submissionTime of the task is set after this call. This does not mean that the job has started - it might be queued.

Returns:

string

bindTo

public void bindTo(io.micrometer.core.instrument.MeterRegistry meterRegistry)

Specified by:

bindTo in interface io.micrometer.core.instrument.binder.MeterBinder