Package io.openems.edge.bridge.modbus.api.worker.internal

Class CycleTasksManager

java.lang.Object

io.openems.edge.bridge.modbus.api.worker.internal.CycleTasksManager

public class CycleTasksManager
extends Object

Manages the Read-, Write- and Wait-Tasks for one Cycle.

onBeforeProcessImage() initialize the next Cycle if previous Cycle had finished

onExecuteWrite() puts Write-Tasks as highest priority

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	CycleTasksManager(TasksSupplier tasksSupplier, DefectiveComponents defectiveComponents, Consumer<Boolean> cycleTimeIsTooShortChannel, Consumer<Long> cycleDelayChannel)
	CycleTasksManager(TasksSupplier tasksSupplier, DefectiveComponents defectiveComponents, Consumer<Boolean> cycleTimeIsTooShortChannel, Consumer<Long> cycleDelayChannel, AtomicReference<LogVerbosity> logVerbosity)

Method Summary

Modifier and Type	Method	Description
Task	getNextTask()	Gets the next Task.
void	onBeforeProcessImage()	Called on BEFORE_PROCESS_IMAGE event.
void	onExecuteWrite()	Called on EXECUTE_WRITE event.

Methods inherited from class java.lang.Object

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

Constructor Details

CycleTasksManager

public CycleTasksManager(TasksSupplier tasksSupplier,
 DefectiveComponents defectiveComponents,
 Consumer<Boolean> cycleTimeIsTooShortChannel,
 Consumer<Long> cycleDelayChannel,
 AtomicReference<LogVerbosity> logVerbosity)

CycleTasksManager

protected CycleTasksManager(TasksSupplier tasksSupplier,
 DefectiveComponents defectiveComponents,
 Consumer<Boolean> cycleTimeIsTooShortChannel,
 Consumer<Long> cycleDelayChannel)

Method Details

onBeforeProcessImage

public void onBeforeProcessImage()

Called on BEFORE_PROCESS_IMAGE event.

onExecuteWrite

public void onExecuteWrite()

Called on EXECUTE_WRITE event.

getNextTask

public Task getNextTask()

Gets the next Task. This is called in a separate Thread by ModbusWorker.

Returns:

next Task