当前位置：首页 > Java

java 如何堵塞线程

2026-03-21 15:31:17Java

堵塞线程的方法

在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 允许一组线程互相等待，直到所有线程都到达某个屏障点。

java 如何堵塞线程

CyclicBarrier barrier = new CyclicBarrier(2);

try {
    barrier.await(); // 堵塞线程，直到所有线程到达
} catch (InterruptedException | BrokenBarrierException e) {
    e.printStackTrace();
}