Package io.openems.edge.bridge.onewire.impl

Class OneWireTaskWorker

java.lang.Object

io.openems.common.worker.AbstractWorker

io.openems.common.worker.AbstractImmediateWorker

io.openems.edge.bridge.onewire.impl.OneWireTaskWorker

public class OneWireTaskWorker
extends AbstractImmediateWorker

Field Summary

Fields inherited from class io.openems.common.worker.AbstractWorker

ALWAYS_WAIT_FOR_TRIGGER_NEXT_RUN, DO_NOT_WAIT, thread

Constructor Summary

Constructors

Constructor	Description
OneWireTaskWorker(BridgeOnewireImpl parent, String port)

Method Summary

Modifier and Type	Method	Description
void	addTask(Consumer<DSPortAdapter> task)	Adds a Task.
void	deactivate()	Stops the worker thread.
protected void	forever()	This method is called in a loop forever until the Thread gets interrupted.
GetDeviceResponse	handleGetDevicesRequest(JsonrpcRequest request)	Handles a GetDevicesRequest.
void	removeTask(Consumer<DSPortAdapter> task)	Removes a Task.

Methods inherited from class io.openems.common.worker.AbstractImmediateWorker

activate, getCycleTime

Methods inherited from class io.openems.common.worker.AbstractWorker

activate, modified, modified, setPriority, triggerNextRun

Methods inherited from class java.lang.Object

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

Constructor Details

OneWireTaskWorker

public OneWireTaskWorker(BridgeOnewireImpl parent,
 String port)

Method Details

forever

protected void forever()
                throws InterruptedException

Description copied from class: AbstractWorker

This method is called in a loop forever until the Thread gets interrupted.

Specified by:

forever in class AbstractImmediateWorker

Throws:

InterruptedException

deactivate

public void deactivate()

Description copied from class: AbstractWorker

Stops the worker thread.

Overrides:

deactivate in class AbstractImmediateWorker

addTask

public void addTask(Consumer<DSPortAdapter> task)

Adds a Task.

Parameters:

task - the task

removeTask

public void removeTask(Consumer<DSPortAdapter> task)

Removes a Task.

Parameters:

task - the task

handleGetDevicesRequest

public GetDeviceResponse handleGetDevicesRequest(JsonrpcRequest request)
                                          throws OpenemsException

Handles a GetDevicesRequest.

Parameters:

request - the JsonrpcRequest

Returns:

a GetDeviceResponse

Throws:

OpenemsException - on error