diff --git a/router/java/src/net/i2p/router/transport/ntcp/Writer.java b/router/java/src/net/i2p/router/transport/ntcp/Writer.java
index cba28fbcf454b88a1266805d9d9e1894c5172135..af5bcb0b987ac2afd6ed059d521e76734ba0a204 100644
--- a/router/java/src/net/i2p/router/transport/ntcp/Writer.java
+++ b/router/java/src/net/i2p/router/transport/ntcp/Writer.java
@@ -80,9 +80,12 @@ class Writer {
     }
     
     private class Runner implements Runnable {
-        private boolean _stop;
-        public Runner() { _stop = false; }
+        private volatile boolean _stop;
+
+        public Runner() {}
+
         public void stop() { _stop = true; }
+
         public void run() {
             if (_log.shouldLog(Log.INFO)) _log.info("Starting writer");
             NTCPConnection con = null;