Searched refs:processFuture (Results 1 – 3 of 3) sorted by relevance
79 private volatile Future<?> processFuture; field in ServerEndpoint111 if (processFuture != null) { in stop()112 processFuture.get(5, TimeUnit.SECONDS); in stop()150 processFuture = executor.submit(new ProcessTask()); in run()
76 private volatile Future<?> processFuture; field in ServerEndpoint108 if (processFuture != null) { in stop()109 processFuture.get(5, TimeUnit.SECONDS); in stop()147 processFuture = executor.submit(new ProcessTask()); in run()
245 final ListenableFuture<Integer> processFuture = streamExecutor.submit(new Callable<Integer>() { in doStop() local257 if (processFuture.get(SHUTDOWN_WAIT_MILLIS, TimeUnit.MILLISECONDS) == 0) { in doStop()265 processFuture.cancel(true); // we don't need it anymore in doStop()