Java & C# port

1 files changed, 3 insertions, 1 deletions

diff --git a/java/src/IceInternal/ThreadPoolCurrent.java b/java/src/IceInternal/ThreadPoolCurrent.java
index 02d471b4af2..93440e73e91 100644
--- a/java/src/IceInternal/ThreadPoolCurrent.java
+++ b/java/src/IceInternal/ThreadPoolCurrent.java
@@ -11,12 +11,13 @@ package IceInternal;
 
 public final class ThreadPoolCurrent
 {
-    ThreadPoolCurrent(Instance instance, ThreadPool threadPool)
+    ThreadPoolCurrent(Instance instance, ThreadPool threadPool, ThreadPool.EventHandlerThread thread)
     {
         operation = SocketOperation.None;
         stream = new BasicStream(instance, Protocol.currentProtocolEncoding);
 
         _threadPool = threadPool;
+        _thread = thread;
         _ioCompleted = false;
         _leader = false;
     }
@@ -31,6 +32,7 @@ public final class ThreadPoolCurrent
     }
     
     final ThreadPool _threadPool;
+    final ThreadPool.EventHandlerThread _thread;
     EventHandler _handler;
     boolean _ioCompleted;
     boolean _leader;