From b9f2fa14fb3f222a6ec5e0a93bf25fe5ad12b56a Mon Sep 17 00:00:00 2001 From: Benoit Foucher Date: Fri, 21 Aug 2009 15:55:01 +0200 Subject: IOCP changes, bug 3501, 4200, 4156, 3101 --- java/src/IceInternal/ThreadPoolCurrent.java | 37 +++++++++++++++++++++++++++++ 1 file changed, 37 insertions(+) create mode 100644 java/src/IceInternal/ThreadPoolCurrent.java (limited to 'java/src/IceInternal/ThreadPoolCurrent.java') diff --git a/java/src/IceInternal/ThreadPoolCurrent.java b/java/src/IceInternal/ThreadPoolCurrent.java new file mode 100644 index 00000000000..6e12af421ad --- /dev/null +++ b/java/src/IceInternal/ThreadPoolCurrent.java @@ -0,0 +1,37 @@ +// ********************************************************************** +// +// Copyright (c) 2003-2009 ZeroC, Inc. All rights reserved. +// +// This copy of Ice is licensed to you under the terms described in the +// ICE_LICENSE file included in this distribution. +// +// ********************************************************************** + +package IceInternal; + +public final class ThreadPoolCurrent +{ + ThreadPoolCurrent(Instance instance, ThreadPool threadPool) + { + operation = SocketOperation.None; + stream = new BasicStream(instance); + + _threadPool = threadPool; + _ioCompleted = false; + _leader = false; + } + + public int operation; + public BasicStream stream; // A per-thread stream to be used by event handlers for optimization. + + public void + ioCompleted() + { + _threadPool.ioCompleted(this); + } + + final ThreadPool _threadPool; + EventHandler _handler; + boolean _ioCompleted; + boolean _leader; +} -- cgit v1.2.3