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) | 如果可以在超时过去之前执行此操作,则将元素传输给使用者。 |