java 如何堵塞线程
堵塞线程的方法
在Java中,可以通过多种方式实现线程的堵塞。以下是几种常见的方法:
使用 Thread.sleep()
Thread.sleep() 方法可以让当前线程暂停执行指定的时间。该方法会抛出 InterruptedException,需要捕获或声明抛出。
try {
Thread.sleep(1000); // 堵塞线程1秒
} catch (InterruptedException e) {
e.printStackTrace();
}
使用 Object.wait()
Object.wait() 方法会让当前线程进入等待状态,直到其他线程调用 notify() 或 notifyAll() 唤醒它。调用 wait() 前必须持有对象的锁。

synchronized (lockObject) {
try {
lockObject.wait(); // 堵塞线程,等待唤醒
} catch (InterruptedException e) {
e.printStackTrace();
}
}
使用 Lock 和 Condition
java.util.concurrent.locks.Lock 接口提供了更灵活的线程堵塞机制,结合 Condition 可以实现精确的线程等待和唤醒。
Lock lock = new ReentrantLock();
Condition condition = lock.newCondition();
lock.lock();
try {
condition.await(); // 堵塞线程,等待唤醒
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
lock.unlock();
}
使用 BlockingQueue
BlockingQueue 是一个线程安全的队列,当队列为空时,take() 方法会堵塞线程,直到队列中有元素。

BlockingQueue<String> queue = new LinkedBlockingQueue<>();
try {
String item = queue.take(); // 堵塞线程,直到队列不为空
} catch (InterruptedException e) {
e.printStackTrace();
}
使用 CountDownLatch
CountDownLatch 是一个同步辅助类,可以让一个或多个线程等待,直到其他线程完成操作。
CountDownLatch latch = new CountDownLatch(1);
try {
latch.await(); // 堵塞线程,直到计数器为0
} catch (InterruptedException e) {
e.printStackTrace();
}
使用 CyclicBarrier
CyclicBarrier 允许一组线程互相等待,直到所有线程都到达某个屏障点。
CyclicBarrier barrier = new CyclicBarrier(2);
try {
barrier.await(); // 堵塞线程,直到所有线程到达
} catch (InterruptedException | BrokenBarrierException e) {
e.printStackTrace();
}
注意事项
- 使用
wait()和await()时,必须确保线程持有正确的锁,否则会抛出IllegalMonitorStateException。 - 堵塞线程时,应正确处理
InterruptedException,避免线程无法正常中断。 - 选择适合场景的堵塞机制,例如
BlockingQueue适合生产者-消费者模型,而CountDownLatch适合一次性等待。






