boolean |
CountDownLatch.await(long timeout, TimeUnit unit) |
|
int |
CyclicBarrier.await(long timeout, TimeUnit unit) |
等待直到所有
parties已经在此屏障上调用了
await ,或指定的等待时间过去。
|
int |
Phaser.awaitAdvanceInterruptibly(int phase, long timeout, TimeUnit unit) |
等待该移相器的相位从给定的相位值或给定的超时时间
InterruptedException 到等待时抛出
InterruptedException ,或者如果当前相位不等于给定的相位值,则立即返回,或者该相位器被终止。
|
boolean |
ForkJoinPool.awaitQuiescence(long timeout, TimeUnit unit) |
|
boolean |
ExecutorService.awaitTermination(long timeout, TimeUnit unit) |
阻止所有任务在关闭请求完成后执行,或发生超时或当前线程中断,以先到者为准。
|
boolean |
ForkJoinPool.awaitTermination(long timeout, TimeUnit unit) |
阻止所有任务在关闭请求完成后执行,或发生超时或当前线程中断,以先到者为准。
|
boolean |
ThreadPoolExecutor.awaitTermination(long timeout, TimeUnit unit) |
|
CompletableFuture<T> |
CompletableFuture.completeOnTimeout(T value, long timeout, TimeUnit unit) |
如果在给定的超时之前未完成,则使用给定值完成此CompletableFuture。
|
long |
TimeUnit.convert(long sourceDuration, TimeUnit sourceUnit) |
将给定单位的给定持续时间转换为本机。
|
static Executor |
CompletableFuture.delayedExecutor(long delay, TimeUnit unit) |
返回一个新的执行程序,它在给定的延迟之后将任务提交给默认的执行程序(或者如果不为正,则不会延迟)。
|
static Executor |
CompletableFuture.delayedExecutor(long delay, TimeUnit unit, Executor executor) |
返回一个新的Executor,它在给定的延迟之后向给定的基本执行器提交一个任务(或者如果非正的则不会延迟)。
|
V |
Exchanger.exchange(V x, long timeout, TimeUnit unit) |
等待另一个线程到达此交换点(除非当前线程为
interrupted或指定的等待时间已过),然后将给定对象传输给它,接收其对象作为回报。
|
T |
CompletableFuture.get(long timeout, TimeUnit unit) |
如果有必要等待这个未来完成的给定时间,然后返回其结果(如果有的话)。
|
V |
ForkJoinTask.get(long timeout, TimeUnit unit) |
如果需要等待最多在给定的时间计算完成,然后检索其结果(如果可用)。
|
V |
Future.get(long timeout, TimeUnit unit) |
如果需要等待最多在给定的时间计算完成,然后检索其结果(如果可用)。
|
V |
FutureTask.get(long timeout, TimeUnit unit) |
|
long |
Delayed.getDelay(TimeUnit unit) |
在给定的时间单位中返回与此对象相关联的剩余延迟。
|
long |
ThreadPoolExecutor.getKeepAliveTime(TimeUnit unit) |
返回线程保持活动时间,这是线程在终止之前可能保持空闲的时间量。
|
<T> List<Future<T>> |
AbstractExecutorService.invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) |
|
<T> List<Future<T>> |
ExecutorService.invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) |
执行给定的任务,返回在所有完成或超时到期时持有其状态和结果的期货列表,以先发生者为准。
|
<T> T |
AbstractExecutorService.invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) |
|
<T> T |
ExecutorService.invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) |
执行给定的任务,返回一个已经成功完成的结果(即,不抛出异常),如果在给定的时间超过之前有的话。
|
boolean |
ArrayBlockingQueue.offer(E e, long timeout, TimeUnit unit) |
在该队列的尾部插入指定的元素,等待指定的等待时间,以使空间在队列已满时变为可用。
|
boolean |
BlockingDeque.offer(E e, long timeout, TimeUnit unit) |
将指定的元素插入由此deque表示的队列中(换句话说,在该deque的尾部),等待指定的等待时间(如果需要空间可用)。
|
boolean |
BlockingQueue.offer(E e, long timeout, TimeUnit unit) |
将指定的元素插入到此队列中,等待指定的等待时间(如有必要)才能使空间变得可用。
|
boolean |
DelayQueue.offer(E e, long timeout, TimeUnit unit) |
将指定的元素插入到此延迟队列中。
|
boolean |
LinkedBlockingDeque.offer(E e, long timeout, TimeUnit unit) |
|
boolean |
LinkedBlockingQueue.offer(E e, long timeout, TimeUnit unit) |
在该队列的尾部插入指定的元素,必要时等待指定的等待时间才能使空间变得可用。
|
boolean |
LinkedTransferQueue.offer(E e, long timeout, TimeUnit unit) |
在该队列的尾部插入指定的元素。
|
boolean |
PriorityBlockingQueue.offer(E e, long timeout, TimeUnit unit) |
将指定的元素插入到此优先级队列中。
|
int |
SubmissionPublisher.offer(T item, long timeout, TimeUnit unit, BiPredicate<Flow.Subscriber<? super T>,? super T> onDrop) |
如果可能,通过异步调用其
onNext 方法将给定项目发布给每个当前订户,阻止任何订阅的资源不可用,直到指定的超时或直到调用者线程中断,此时给定的处理程序(如果非-null)被调用,如果返回true,则重试一次。
|
boolean |
SynchronousQueue.offer(E e, long timeout, TimeUnit unit) |
将指定的元素插入到此队列中,如果需要,等待另一个线程接收到的指定等待时间。
|
boolean |
BlockingDeque.offerFirst(E e, long timeout, TimeUnit unit) |
在此deque的前面插入指定的元素,等待指定的等待时间(如果需要空间可用)。
|
boolean |
LinkedBlockingDeque.offerFirst(E e, long timeout, TimeUnit unit) |
|
boolean |
BlockingDeque.offerLast(E e, long timeout, TimeUnit unit) |
在此deque的末尾插入指定的元素,如果需要空间可用,等待指定的等待时间。
|
boolean |
LinkedBlockingDeque.offerLast(E e, long timeout, TimeUnit unit) |
|
CompletableFuture<T> |
CompletableFuture.orTimeout(long timeout, TimeUnit unit) |
|
E |
ArrayBlockingQueue.poll(long timeout, TimeUnit unit) |
|
E |
BlockingDeque.poll(long timeout, TimeUnit unit) |
检索并删除由此deque(换句话说,该deque的第一个元素)表示的队列的头部,等待到指定的等待时间(如有必要)使元素变为可用。
|
E |
BlockingQueue.poll(long timeout, TimeUnit unit) |
检索并删除此队列的头,等待指定的等待时间(如有必要)使元素变为可用。
|
Future<V> |
CompletionService.poll(long timeout, TimeUnit unit) |
检索并删除表示下一个完成的任务的未来,如果还没有,则等待必要时直到指定的等待时间。
|
E |
DelayQueue.poll(long timeout, TimeUnit unit) |
检索并删除此队列的头部,如果需要,等待具有到期延迟的元素可用于此队列,或指定的等待时间到期。
|
Future<V> |
ExecutorCompletionService.poll(long timeout, TimeUnit unit) |
|
E |
LinkedBlockingDeque.poll(long timeout, TimeUnit unit) |
|
E |
LinkedBlockingQueue.poll(long timeout, TimeUnit unit) |
|
E |
LinkedTransferQueue.poll(long timeout, TimeUnit unit) |
|
E |
PriorityBlockingQueue.poll(long timeout, TimeUnit unit) |
|
E |
SynchronousQueue.poll(long timeout, TimeUnit unit) |
检索并删除此队列的头,如果需要等待指定的等待时间,另一个线程插入它。
|
E |
BlockingDeque.pollFirst(long timeout, TimeUnit unit) |
检索并删除此deque的第一个元素,等待到指定的等待时间(如有必要)使元素变为可用。
|
E |
LinkedBlockingDeque.pollFirst(long timeout, TimeUnit unit) |
|
E |
BlockingDeque.pollLast(long timeout, TimeUnit unit) |
检索并删除此deque的最后一个元素,等待到指定的等待时间,如果需要,元素可用。
|
E |
LinkedBlockingDeque.pollLast(long timeout, TimeUnit unit) |
|
ScheduledFuture<?> |
ScheduledExecutorService.schedule(Runnable command, long delay, TimeUnit unit) |
创建并执行在给定延迟后启用的单次操作。
|
<V> ScheduledFuture<V> |
ScheduledExecutorService.schedule(Callable<V> callable, long delay, TimeUnit unit) |
创建并执行在给定延迟后启用的ScheduledFuture。
|
ScheduledFuture<?> |
ScheduledThreadPoolExecutor.schedule(Runnable command, long delay, TimeUnit unit) |
|
<V> ScheduledFuture<V> |
ScheduledThreadPoolExecutor.schedule(Callable<V> callable, long delay, TimeUnit unit) |
|
ScheduledFuture<?> |
ScheduledExecutorService.scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit) |
创建并执行在给定的初始延迟之后,随后以给定的时间段首先启用的周期性动作;
也就是说,执行将在initialDelay 之后开始,然后是initialDelay + period ,然后是initialDelay + 2 * period ,等等。
|
ScheduledFuture<?> |
ScheduledThreadPoolExecutor.scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit) |
|
ScheduledFuture<?> |
ScheduledExecutorService.scheduleWithFixedDelay(Runnable command, long initialDelay, long delay, TimeUnit unit) |
创建并执行在给定的初始延迟之后首先启用的定期动作,随后在一个执行的终止和下一个执行的开始之间给定的延迟。
|
ScheduledFuture<?> |
ScheduledThreadPoolExecutor.scheduleWithFixedDelay(Runnable command, long initialDelay, long delay, TimeUnit unit) |
|
void |
ThreadPoolExecutor.setKeepAliveTime(long time, TimeUnit unit) |
设置线程保持活动时间,这是线程在终止之前可能保持空闲的时间量。
|
boolean |
Semaphore.tryAcquire(int permits, long timeout, TimeUnit unit) |
|
boolean |
Semaphore.tryAcquire(long timeout, TimeUnit unit) |
|
boolean |
LinkedTransferQueue.tryTransfer(E e, long timeout, TimeUnit unit) |
如果可以在超时过程之前将元素传送给消费者。
|
boolean |
TransferQueue.tryTransfer(E e, long timeout, TimeUnit unit) |
如果可以在超时过程之前将元素传送给消费者。
|