当前位置：首页 > Java

java 如何阻塞线程

2026-02-05 02:29:52Java

阻塞线程的方法

在Java中，可以通过多种方式实现线程的阻塞。以下是几种常见的方法：

使用 `Thread.sleep()`

Thread.sleep() 方法可以让当前线程暂停执行指定的时间（毫秒或纳秒），但不会释放锁。

try {
    Thread.sleep(1000); // 阻塞1秒
} catch (InterruptedException e) {
    e.printStackTrace();
}

使用 `Object.wait()`

Object.wait() 方法会让当前线程进入等待状态，直到其他线程调用 notify() 或 notifyAll()。调用 wait() 会释放对象锁。

java 如何阻塞线程

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() 方法会阻塞线程，直到队列中有元素。

java 如何阻塞线程

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();
}

注意事项

阻塞线程时，通常需要处理 InterruptedException，以避免线程被意外中断时出现问题。
使用 wait() 和 Condition.await() 时，必须持有相应的锁，否则会抛出 IllegalMonitorStateException。
选择合适的阻塞机制取决于具体场景，例如是否需要释放锁、是否需要等待其他线程等。