Package io.jmix.flowui.backgroundtask.impl

Class BackgroundTaskWatchDogImpl

java.lang.Object

io.jmix.flowui.backgroundtask.impl.BackgroundTaskWatchDogImpl

All Implemented Interfaces:

BackgroundTaskWatchDog

@ThreadSafe
public class BackgroundTaskWatchDogImpl
extends Object
implements BackgroundTaskWatchDog

Implementation of BackgroundTaskWatchDog for BackgroundWorker.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	BackgroundTaskWatchDogImpl.ExecutionStatus

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	initialized
protected FlowuiBackgroundTaskProperties	properties
protected TimeSource	timeSource

Constructor Summary

Constructors

Constructor	Description
BackgroundTaskWatchDogImpl(FlowuiBackgroundTaskProperties properties, TimeSource timeSource)

Method Summary

Modifier and Type	Method	Description
void	cleanupTasks()	Removes finished, canceled or hangup tasks.
int	getActiveTasksCount()
protected BackgroundTaskWatchDogImpl.ExecutionStatus	getExecutionStatus(long actualTimeMs, TaskHandlerImpl taskHandler)
void	manageTask(TaskHandlerImpl taskHandler)	Adds task under BackgroundTaskWatchDog control.
void	onContextRefreshed()
void	onContextStopped()
void	removeTask(TaskHandlerImpl taskHandler)	Task completed, remove it from watches.
void	stopTasks()	Stops execution of all background tasks.

Methods inherited from class java.lang.Object

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

Field Details

timeSource

protected TimeSource timeSource

properties

protected FlowuiBackgroundTaskProperties properties

initialized

protected volatile boolean initialized

Constructor Details

BackgroundTaskWatchDogImpl

public BackgroundTaskWatchDogImpl(FlowuiBackgroundTaskProperties properties,
 TimeSource timeSource)

Method Details

onContextRefreshed

@EventListener(classes={org.springframework.context.event.ContextRefreshedEvent.class,org.springframework.context.event.ContextStartedEvent.class})
public void onContextRefreshed()

onContextStopped

@EventListener(org.springframework.context.event.ContextStoppedEvent.class)
public void onContextStopped()

cleanupTasks

public void cleanupTasks()

Description copied from interface: BackgroundTaskWatchDog

Removes finished, canceled or hangup tasks.

Specified by:

cleanupTasks in interface BackgroundTaskWatchDog

stopTasks

public void stopTasks()

Description copied from interface: BackgroundTaskWatchDog

Stops execution of all background tasks.

Specified by:

stopTasks in interface BackgroundTaskWatchDog

getActiveTasksCount

public int getActiveTasksCount()

Specified by:

getActiveTasksCount in interface BackgroundTaskWatchDog

Returns:

active tasks count

manageTask

public void manageTask(TaskHandlerImpl taskHandler)

Description copied from interface: BackgroundTaskWatchDog

Adds task under BackgroundTaskWatchDog control.

Specified by:

manageTask in interface BackgroundTaskWatchDog

Parameters:

taskHandler - task handler

removeTask

public void removeTask(TaskHandlerImpl taskHandler)

Description copied from interface: BackgroundTaskWatchDog

Task completed, remove it from watches.

Specified by:

removeTask in interface BackgroundTaskWatchDog

Parameters:

taskHandler - task handler

getExecutionStatus

protected BackgroundTaskWatchDogImpl.ExecutionStatus getExecutionStatus(long actualTimeMs,
 TaskHandlerImpl taskHandler)