Package com.zendesk.maxwell.util
Class StoppableTaskState
- java.lang.Object
-
- com.zendesk.maxwell.util.StoppableTaskState
-
public class StoppableTaskState extends Object
-
-
Constructor Summary
Constructors Constructor Description StoppableTaskState(String description)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
awaitStop(Thread t, long timeoutMS)
RunState
getState()
boolean
isRunning()
void
requestStop()
void
stopped()
-
-
-
Constructor Detail
-
StoppableTaskState
public StoppableTaskState(String description)
-
-
Method Detail
-
isRunning
public boolean isRunning()
-
requestStop
public void requestStop()
-
stopped
public void stopped()
-
awaitStop
public void awaitStop(Thread t, long timeoutMS) throws TimeoutException
- Throws:
TimeoutException
-
getState
public RunState getState()
-
-