Package com.neovisionaries.ws.client
Class SocketInitiator.SocketRacer
- java.lang.Object
-
- java.lang.Thread
-
- com.neovisionaries.ws.client.SocketInitiator.SocketRacer
-
- All Implemented Interfaces:
java.lang.Runnable
- Enclosing class:
- SocketInitiator
private class SocketInitiator.SocketRacer extends java.lang.Thread
This thread connects to a socket and notifies aSocketInitiator.SocketFuture
shared across all racer threads when it is done. A racer thread is done when...- it has established a connection, or
- when establishing a connection failed with an exception, or
- another racer established a connection.
-
-
Field Summary
Fields Modifier and Type Field Description private int
mConnectTimeout
private SocketInitiator.Signal
mDoneSignal
private SocketInitiator.SocketFuture
mFuture
private java.lang.String[]
mServerNames
private java.net.SocketAddress
mSocketAddress
private javax.net.SocketFactory
mSocketFactory
private SocketInitiator.Signal
mStartSignal
-
Constructor Summary
Constructors Constructor Description SocketRacer(SocketInitiator.SocketFuture future, javax.net.SocketFactory socketFactory, java.net.SocketAddress socketAddress, java.lang.String[] serverNames, int connectTimeout, SocketInitiator.Signal startSignal, SocketInitiator.Signal doneSignal)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description (package private) void
abort(java.lang.Exception exception)
private void
complete(java.net.Socket socket)
void
run()
-
Methods inherited from class java.lang.Thread
activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield
-
-
-
-
Field Detail
-
mFuture
private final SocketInitiator.SocketFuture mFuture
-
mSocketFactory
private final javax.net.SocketFactory mSocketFactory
-
mSocketAddress
private final java.net.SocketAddress mSocketAddress
-
mServerNames
private java.lang.String[] mServerNames
-
mConnectTimeout
private final int mConnectTimeout
-
mStartSignal
private final SocketInitiator.Signal mStartSignal
-
mDoneSignal
private final SocketInitiator.Signal mDoneSignal
-
-
Constructor Detail
-
SocketRacer
SocketRacer(SocketInitiator.SocketFuture future, javax.net.SocketFactory socketFactory, java.net.SocketAddress socketAddress, java.lang.String[] serverNames, int connectTimeout, SocketInitiator.Signal startSignal, SocketInitiator.Signal doneSignal)
-
-