Searched refs:selectThread (Results 1 – 4 of 4) sorted by relevance
| /thrift-3.4.0/lib/java/src/main/java/org/apache/thrift/async/ |
| D | TAsyncClientManager.java | 40 private final SelectThread selectThread; field in TAsyncClientManager
45 this.selectThread = new SelectThread(); in TAsyncClientManager()
46 selectThread.start(); in TAsyncClientManager()
55 selectThread.getSelector().wakeup(); in call()
59 selectThread.finish(); in stop()
63 return selectThread.isAlive(); in isRunning()
|
| /thrift-3.4.0/lib/java/src/main/java/org/apache/thrift/server/ |
| D | TNonblockingServer.java | 206 final AbstractSelectThread selectThread) in createFrameBuffer() argument
209 ? new AsyncFrameBuffer(trans, selectionKey, selectThread) in createFrameBuffer()
210 : new FrameBuffer(trans, selectionKey, selectThread); in createFrameBuffer()
|
| D | AbstractNonblockingServer.java | 284 final AbstractSelectThread selectThread) in FrameBuffer() argument
288 selectThread_ = selectThread; in FrameBuffer()
546 TNonblockingTransport trans, SelectionKey selectionKey, AbstractSelectThread selectThread) in AsyncFrameBuffer() argument
548 super(trans, selectionKey, selectThread); in AsyncFrameBuffer()
|
| D | TThreadedSelectorServer.java | 664 final AbstractSelectThread selectThread) in createFrameBuffer() argument
667 ? new AsyncFrameBuffer(trans, selectionKey, selectThread) in createFrameBuffer()
668 : new FrameBuffer(trans, selectionKey, selectThread); in createFrameBuffer()
|
