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 ,或者如果当前相位不等于给定相位值或该相位器终止则立即返回。
|
boolean |
ForkJoinPool.awaitQuiescence(long timeout, TimeUnit unit) |
|
boolean |
ExecutorService.awaitTermination(long timeout, TimeUnit unit) |
阻止所有任务在关闭请求之后完成执行,或发生超时,或者当前线程被中断,以先发生者为准。
|
boolean |
ForkJoinPool.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) |
返回一个新的Executor,它在给定的延迟之后将任务提交给默认执行程序(如果非正数则没有延迟)。
|
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>> |
ExecutorService.invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) |
执行给定的任务,返回一个Futures列表,在完成或超时到期时保持其状态和结果,以先发生者为准。
|
<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) |
将指定的元素插入此双端队列表示的队列中(换句话说,在此双端队列的尾部),如果需要空间可用,则等待指定的等待时间。
|
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) |
在此双端队列的前面插入指定的元素,如有必要,等待指定的等待时间以使空间可用。
|
boolean |
LinkedBlockingDeque.offerFirst(E e, long timeout, TimeUnit unit) |
|
boolean |
BlockingDeque.offerLast(E e, long timeout, TimeUnit unit) |
在此双端队列的末尾插入指定的元素,如果需要空间可用,则等待指定的等待时间。
|
boolean |
LinkedBlockingDeque.offerLast(E e, long timeout, TimeUnit unit) |
|
CompletableFuture<T> |
CompletableFuture.orTimeout(long timeout, TimeUnit unit) |
|
E |
BlockingDeque.poll(long timeout, TimeUnit unit) |
检索并移除此双端队列表示的队列的头部(换句话说,此双端队列的第一个元素),等待指定的等待时间(如果需要,则元素变为可用)。
|
E |
BlockingQueue.poll(long timeout, TimeUnit unit) |
检索并删除此队列的头部,如果元素可用,则等待指定的等待时间。
|
Future<V> |
CompletionService.poll(long timeout, TimeUnit unit) |
检索并删除表示下一个已完成任务的Future,必要时等待指定的等待时间(如果尚未存在)。
|
E |
DelayQueue.poll(long timeout, TimeUnit unit) |
检索并删除此队列的头部,必要时等待,直到此队列上具有过期延迟的元素或指定的等待时间到期为止。
|
E |
SynchronousQueue.poll(long timeout, TimeUnit unit) |
检索并删除此队列的头部,在必要时等待指定的等待时间,以便另一个线程插入它。
|
E |
BlockingDeque.pollFirst(long timeout, TimeUnit unit) |
检索并删除此双端队列的第一个元素,如果元素可用,则等待指定的等待时间。
|
E |
BlockingDeque.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<?> |
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) |
提交定期操作,该操作在给定的初始延迟后首先启用,随后在给定的时间段内启用;
也就是说,执行将在initialDelay 之后开始,然后是initialDelay + period ,然后是initialDelay + 2 * period ,依此类推。
|
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) |
如果在给定的等待时间内所有许可都可用且当前线程不是
interrupted ,则从此信号量获取给定数量的许可。
|
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) |
如果可以在超时过去之前执行此操作,则将元素传输给使用者。
|