com.jn.langx.util.concurrent

类 Uninterrupteds

java.lang.Object

com.jn.langx.util.concurrent.Uninterrupteds

public final class Uninterrupteds
extends Object

Utilities for treating interruptible operations as uninterruptible. In all cases, if a thread is interrupted during such a call, the call continues to block until the result is available or the timeout elapses, and only then re-interrupts the thread.

从以下版本开始:

2.10.3

作者:

Anthony Zana

方法概要

限定符和类型	方法和说明
static void	awaitUninterrupted(CountDownLatch latch) Invokes latch.
static boolean	awaitUninterrupted(CountDownLatch latch, long timeout, TimeUnit unit) Invokes latch.
static <V> V	getUninterrupted(Future<V> future) Invokes future.
static <V> V	getUninterrupted(Future<V> future, long timeout, TimeUnit unit) Invokes future.
static void	joinUninterrupted(Thread toJoin) Invokes toJoin.
static void	joinUninterrupted(Thread toJoin, long timeout, TimeUnit unit) Invokes unit.
static <E> void	putUninterrupted(BlockingQueue<E> queue, E element) Invokes queue.
static void	sleepUninterrupted(long sleepFor, TimeUnit unit) Invokes unit.
static <E> E	takeUninterrupted(BlockingQueue<E> queue) Invokes queue.
static boolean	tryAcquireUninterrupted(Semaphore semaphore, int permits, long timeout, TimeUnit unit) Invokes semaphore.
static boolean	tryAcquireUninterrupted(Semaphore semaphore, long timeout, TimeUnit unit) Invokes semaphore.

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

方法详细资料

awaitUninterrupted

public static void awaitUninterrupted(CountDownLatch latch)

Invokes latch.await() uninterrupted.

awaitUninterrupted

public static boolean awaitUninterrupted(CountDownLatch latch,
                                         long timeout,
                                         TimeUnit unit)

Invokes latch.await(timeout, unit) uninterrupted.

joinUninterrupted

public static void joinUninterrupted(Thread toJoin)

Invokes toJoin.join() uninterrupted.

getUninterrupted

public static <V> V getUninterrupted(Future<V> future)
                              throws ExecutionException

Invokes future.get() uninterrupted.

抛出:

ExecutionException - if the computation threw an exception

CancellationException - if the computation was cancelled

getUninterrupted

public static <V> V getUninterrupted(Future<V> future,
                                     long timeout,
                                     TimeUnit unit)
                              throws ExecutionException,
                                     TimeoutException

Invokes future.get(timeout, unit) uninterrupted.

抛出:

ExecutionException - if the computation threw an exception

CancellationException - if the computation was cancelled

TimeoutException - if the wait timed out

joinUninterrupted

public static void joinUninterrupted(Thread toJoin,
                                     long timeout,
                                     TimeUnit unit)

Invokes unit.timedJoin(toJoin, timeout) uninterrupted.

takeUninterrupted

public static <E> E takeUninterrupted(BlockingQueue<E> queue)

Invokes queue.take() uninterrupted.

putUninterrupted

public static <E> void putUninterrupted(BlockingQueue<E> queue,
                                        E element)

Invokes queue.put(element) uninterrupted.

抛出:

ClassCastException - if the class of the specified element prevents it from being added to the given queue

IllegalArgumentException - if some property of the specified element prevents it from being added to the given queue

sleepUninterrupted

public static void sleepUninterrupted(long sleepFor,
                                      TimeUnit unit)

Invokes unit.sleep(sleepFor) uninterrupted.

tryAcquireUninterrupted

public static boolean tryAcquireUninterrupted(Semaphore semaphore,
                                              long timeout,
                                              TimeUnit unit)

Invokes semaphore.tryAcquire(1, timeout, unit) uninterrupted.

从以下版本开始:

2.10.3

tryAcquireUninterrupted

public static boolean tryAcquireUninterrupted(Semaphore semaphore,
                                              int permits,
                                              long timeout,
                                              TimeUnit unit)

Invokes semaphore.tryAcquire(permits, timeout, unit) uninterrupted.

从以下版本开始:

2.10.3