diff --git a/router/java/src/net/i2p/router/JobImpl.java b/router/java/src/net/i2p/router/JobImpl.java index 21ee8f9d7d10bee54e7b672c688c592f135f35d4..25431e20b0b251309ddd922f11306f2673dd5659 100644 --- a/router/java/src/net/i2p/router/JobImpl.java +++ b/router/java/src/net/i2p/router/JobImpl.java @@ -18,10 +18,10 @@ import java.util.concurrent.atomic.AtomicLong; public abstract class JobImpl implements Job { private final RouterContext _context; private final JobTiming _timing; - private static AtomicLong _idSrc = new AtomicLong(); + private static final AtomicLong _idSrc = new AtomicLong(); private final long _id; //private Exception _addedBy; - private long _madeReadyOn; + private volatile long _madeReadyOn; public JobImpl(RouterContext context) { _context = context; diff --git a/router/java/src/net/i2p/router/JobTiming.java b/router/java/src/net/i2p/router/JobTiming.java index 818203aeb916868b67b558a869e66c1de394b599..98d8e67c7fced05cb5018d89b7c350fc1d99e1f3 100644 --- a/router/java/src/net/i2p/router/JobTiming.java +++ b/router/java/src/net/i2p/router/JobTiming.java @@ -16,9 +16,9 @@ import net.i2p.util.Clock; * For use by the router only. Not to be used by applications or plugins. */ public class JobTiming implements Clock.ClockUpdateListener { - private long _start; - private long _actualStart; - private long _actualEnd; + private volatile long _start; + private volatile long _actualStart; + private volatile long _actualEnd; private final RouterContext _context; public JobTiming(RouterContext context) {