java如何使线程暂停

2025-06-21 20:02:49

在Java中，你可以使用几种方法来暂停线程，包括使用Thread.sleep()方法、使用Object.wait()和notify()方法、使用Lock和Condition、使用Semaphore信号量、使用CyclicBarrier循环栅栏和CountDownLatch倒计时门闩。每种方法都有它的使用场景和优缺点，选择哪种方法取决于你的具体需求和场景。

首先，我们来详细探讨一下使用Thread.sleep()方法暂停线程的方式。

一、使用Thread.sleep()方法

Thread.sleep()方法是最常用的使线程暂停的方法。当调用这个方法时，当前线程会被暂停一段时间，这段时间是以毫秒为单位的。Thread.sleep()方法会让出CPU资源，但不会释放锁资源，所以如果线程持有某个对象的锁，在睡眠期间其他线程是无法获取这个对象的锁的。

例如，下面的代码会创建一个新的线程，然后在这个线程中使用Thread.sleep()方法使线程暂停1秒：

Thread thread = new Thread(new Runnable() {

@Override

public void run() {

try {

Thread.sleep(1000);

} catch (InterruptedException e) {

e.printStackTrace();

}

});

thread.start();

在这段代码中，新创建的线程会立即进入睡眠状态，睡眠1秒后再继续执行。需要注意的是，Thread.sleep()方法会抛出InterruptedException异常，所以需要在代码中处理这个异常。

二、使用Object.wait()和notify()方法

Object类的wait()和notify()方法也可以用来控制线程的暂停和恢复。和Thread.sleep()方法不同，wait()方法会让出CPU资源，并且会释放对象的锁，使得其他线程可以获取这个对象的锁。

例如，下面的代码会创建一个新的线程，然后在这个线程中使用wait()方法使线程暂停，直到其他线程调用同一对象的notify()方法：

final Object lock = new Object();

Thread thread = new Thread(new Runnable() {

@Override

public void run() {

synchronized (lock) {

try {

lock.wait();

} catch (InterruptedException e) {

e.printStackTrace();

}

});

thread.start();

// Some time later...

synchronized (lock) {

lock.notify();

}

在这段代码中，新创建的线程会立即进入等待状态，等待直到其他线程调用同一对象的notify()方法后才会继续执行。需要注意的是，wait()方法和notify()方法都需要在同步代码块中使用，否则会抛出IllegalMonitorStateException异常。

三、使用Lock和Condition

Java并发包java.util.concurrent中的Lock和Condition接口也可以用来控制线程的暂停和恢复。Lock接口提供了比synchronized关键字更强大的锁功能，Condition接口提供了线程之间的协调功能。

例如，下面的代码使用Lock和Condition接口来控制线程的暂停和恢复：

final Lock lock = new ReentrantLock();

final Condition condition = lock.newCondition();

Thread thread = new Thread(new Runnable() {

@Override

public void run() {

lock.lock();

try {

condition.await();

} catch (InterruptedException e) {

e.printStackTrace();

} finally {

lock.unlock();

}

});

thread.start();

// Some time later...

lock.lock();

try {

condition.signal();

} finally {

lock.unlock();

}

在这段代码中，新创建的线程会立即进入等待状态，等待直到其他线程调用同一Condition的signal()方法后才会继续执行。需要注意的是，await()方法和signal()方法都需要在lock.lock()和lock.unlock()之间使用，否则会抛出IllegalMonitorStateException异常。

四、使用Semaphore信号量

Semaphore信号量是一个计数信号量，可以用来控制同时访问特定资源的线程数量。通过调用Semaphore的acquire()方法获取一个许可，如果当前信号量的计数器为0，那么线程会阻塞直到有一个可用的许可。

例如，下面的代码使用Semaphore信号量来控制线程的暂停和恢复：

final Semaphore semaphore = new Semaphore(0);

Thread thread = new Thread(new Runnable() {

@Override

public void run() {

try {

semaphore.acquire();

} catch (InterruptedException e) {

e.printStackTrace();

}

});

thread.start();

// Some time later...

semaphore.release();

在这段代码中，新创建的线程会立即进入阻塞状态，等待直到其他线程调用同一Semaphore的release()方法后才会继续执行。需要注意的是，Semaphore的构造函数需要一个初始许可数量，这个数量可以为0，表示没有可用的许可。

五、使用CyclicBarrier循环栅栏和CountDownLatch倒计时门闩

CyclicBarrier循环栅栏和CountDownLatch倒计时门闩也可以用来控制线程的暂停和恢复。CyclicBarrier循环栅栏允许一组线程相互等待，直到所有的线程都到达一个公共的屏障点（barrier point）。CountDownLatch倒计时门闩是一次性的，它允许一组线程等待，直到倒计时到0。

例如，下面的代码使用CyclicBarrier循环栅栏来控制线程的暂停和恢复：

final CyclicBarrier barrier = new CyclicBarrier(2);

Thread thread = new Thread(new Runnable() {

@Override

public void run() {

try {

barrier.await();

} catch (InterruptedException | BrokenBarrierException e) {

e.printStackTrace();

}

});

thread.start();

// Some time later...

try {

barrier.await();

} catch (InterruptedException | BrokenBarrierException e) {

e.printStackTrace();

}

在这段代码中，新创建的线程会立即进入等待状态，等待直到其他线程也到达同一CyclicBarrier后才会继续执行。需要注意的是，CyclicBarrier的构造函数需要一个参与者数量，这个数量表示到达屏障点的线程数量。

以上就是在Java中使线程暂停的几种主要方法，每种方法都有它的使用场景和优缺点，选择哪种方法取决于你的具体需求和场景。