Java 可中止线程

方法

超时后的处理

ReentrantLock

ReadLock

WriteLock

tryLock(long, TimeUnit)

返回false

Condition

await(long, TimeUnit)

awaitNanos(long)

awaitUntil(Date)

返回false

Future

get(long, TimeUnit)

TimeoutException

CyclicBarrier

await(long, TimeUnit)

TimeoutException

CountDownLatch

await(long, TimeUnit)

返回false

Exchanger

exchange(V, long, TimeUnit)

TimeoutException

Semaphore

tryAcquire(long, TimeUnit)

返回false

BlockingQueue<E>

offer(E, long, TimeUnit)

poll(long, TimeUnit)

返回false

返回null

BlockingDeque<E>

offerFirst(E, long, TimeUnit)

offerLast(E, long, TimeUnit)

poolFirst(long, TimeUnit)

poolLast(long, TimeUnit)

返回false

?

返回null

ServerSocket

accept()

通过setSoTimeout设置超时时间。

SocketTimeoutException

?

类

方法

异常

Thread

sleep(long)

join()

InterruptedException

?

ReentrantLock

ReadLock

WriteLock

lockInterruptibly()

InterruptedException

Condition

await()

InterruptedException

Future

get()

InterruptedException

CyclicBarrier

await()

InterruptedException

CountDownLatch

await()

InterruptedException

Exchanger

exchange(V)

InterruptedException

Semaphore

acquire()

InterruptedException

BlockingQueue<E>

put(E)

take()

InterruptedException

BlockingDeque<E>

putFirst(E)

putLast(E)

takeFirst(E)

takeLast(E)

InterruptedException

?

类

阻塞方法

可中断方法

ReentrantLock

ReadLock

WriteLock

lock()

tryLock()

tryLock(long, TimeUnit)

lockInterruptibly()

Condition

awaitUninterruptibly()

await()

await(long, TimeUnit)

awaitNanos(long)

awaitUntil(Date)

Semaphore

acquireUninterruptibly()

acquire()

tryAcquire()

tryAcquire(long, TimeUnit)

synchronized块，Object的wait方法。可以使用ReentrantLock和Condition替代。
BufferedReader的readLine方法，ObjectInputStream得readObject方法。（如果底层流是通过Socket获得，可以通过Socket设置超时）

PART.5?处理Thread.sleep()

1.?捕获异常并结束线程