simpledb.parallel

Class Worker.WorkerLivenessController

java.lang.Object

java.util.TimerTask

simpledb.parallel.Worker.WorkerLivenessController

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

Worker

public static class Worker.WorkerLivenessController
extends java.util.TimerTask

The controller class which decides whether this worker should shutdown or not. 1) it detects whether the server is still alive. If the server got killed because of any reason, the workers will be terminated. 2) it detects whether a shutdown message is received.

Field Summary

Fields

Modifier and Type	Field and Description
private boolean	inRun
(package private) Worker	thisWorker
private java.util.Timer	timer

Constructor Summary

Constructors

Constructor and Description
Worker.WorkerLivenessController(Worker worker)

Method Summary

Methods

Modifier and Type	Method and Description
void	run()
void	start()

Methods inherited from class java.util.TimerTask

cancel, scheduledExecutionTime

Methods inherited from class java.lang.Object

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

Field Detail

timer

private final java.util.Timer timer

inRun

private volatile boolean inRun

thisWorker

final Worker thisWorker

Constructor Detail

Worker.WorkerLivenessController

public Worker.WorkerLivenessController(Worker worker)

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

Specified by:

run in class java.util.TimerTask

start

public void start()