RunLoopProcess (maxwell 1.41.1 API)

java.lang.Object
- com.zendesk.maxwell.util.RunLoopProcess

All Implemented Interfaces:

StoppableTask

Direct Known Subclasses:

BinlogConnectorReplicator, BootstrapController, MysqlSchemaCompactor, PositionStoreThread
```
public abstract class RunLoopProcess
extends Object
implements StoppableTask
```

Field Summary

Fields
Modifier and Type Field Description

protected StoppableTaskState taskState

Constructor Summary

Constructors
Constructor Description

RunLoopProcess()

Method Summary

All Methods Instance Methods Abstract Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`awaitStop(Long timeout)`
`protected void`	`beforeStart()`
`protected void`	`beforeStop()`
`void`	`interrupt()`
`void`	`requestStop()`
`void`	`runLoop()`
`protected abstract void`	`work()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

taskState

protected volatile StoppableTaskState taskState

Constructor Detail
- RunLoopProcess
```
public RunLoopProcess()
```

Method Detail

requestStop
```
public void requestStop()
```
Specified by:

requestStop in interface StoppableTask

interrupt
```
public void interrupt()
```

awaitStop

public void awaitStop(Long timeout)
               throws TimeoutException

Specified by:: awaitStop in interface StoppableTask
Throws:: TimeoutException

runLoop

public void runLoop()
             throws Exception

Throws:: Exception

work

protected abstract void work()
                      throws Exception

Throws:: Exception

beforeStart

protected void beforeStart()
                    throws Exception

Throws:: Exception

beforeStop

protected void beforeStop()
                   throws Exception

Throws:: Exception