more volatiles

This commit is contained in:
zab2
2013-06-26 21:03:18 +00:00
parent f525685765
commit ec70f2420c
2 changed files with 7 additions and 7 deletions

View File

@ -53,7 +53,7 @@ public class JobQueue {
/** will we allow the # job runners to grow beyond 1? */
private boolean _allowParallelOperation;
/** have we been killed or are we alive? */
private boolean _alive;
private volatile boolean _alive;
private final Object _jobLock;
private volatile long _nextPumperRun;

View File

@ -6,13 +6,13 @@ import net.i2p.util.Log;
class JobQueueRunner implements Runnable {
private final Log _log;
private final RouterContext _context;
private boolean _keepRunning;
private volatile boolean _keepRunning;
private final int _id;
private Job _currentJob;
private Job _lastJob;
private long _lastBegin;
private long _lastEnd;
private int _state;
private volatile Job _currentJob;
private volatile Job _lastJob;
private volatile long _lastBegin;
private volatile long _lastEnd;
private volatile int _state;
public JobQueueRunner(RouterContext context, int id) {
_context = context;