From ec70f2420cc0ea6fcd33c0e621f45b215f4d571d Mon Sep 17 00:00:00 2001
From: zab2 <zab2@mail.i2p>
Date: Wed, 26 Jun 2013 21:03:18 +0000
Subject: [PATCH] more volatiles
---
router/java/src/net/i2p/router/JobQueue.java | 2 +-
router/java/src/net/i2p/router/JobQueueRunner.java | 12 ++++++------
2 files changed, 7 insertions(+), 7 deletions(-)
diff --git a/router/java/src/net/i2p/router/JobQueue.java b/router/java/src/net/i2p/router/JobQueue.java
index 6abbbe1519..5ec9e7e656 100644
--- a/router/java/src/net/i2p/router/JobQueue.java
+++ b/router/java/src/net/i2p/router/JobQueue.java
@@ -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;
diff --git a/router/java/src/net/i2p/router/JobQueueRunner.java b/router/java/src/net/i2p/router/JobQueueRunner.java
index 12cd2b2dde..b9ae2363d7 100644
--- a/router/java/src/net/i2p/router/JobQueueRunner.java
+++ b/router/java/src/net/i2p/router/JobQueueRunner.java
@@ -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;
--
GitLab