Java多线程间如何通信

发布时间：2025-02-26 21:41:05 阅读：86 作者：小樊栏目：编程语言

Java开发者专用服务器限时活动，0元免费领，库存有限，领完即止！点击查看>>

在Java中，多线程间通信主要通过以下几种方式实现：

wait() 和 notify() 方法：这两个方法用于线程间的协作，它们是 Object 类的一部分。当一个线程调用另一个线程的 wait() 方法时，当前线程会释放锁并进入等待状态。当另一个线程调用同一个对象的 notify() 方法时，等待状态的线程会被唤醒并重新获取锁。这种方式主要用于生产者-消费者问题。

示例：

synchronized (lock) {
    try {
        lock.wait();
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
}

// 在其他线程中
synchronized (lock) {
    lock.notify();
}

Condition 接口： Condition 接口提供了更灵活的线程间通信机制，它也是与锁相关联的。一个 Lock 对象可以有多个 Condition 对象，每个 Condition 对象都代表了一个等待集。线程可以通过调用 await() 方法进入等待集，通过调用 signal() 或 signalAll() 方法唤醒等待集中的线程。

示例：

Lock lock = new ReentrantLock();
Condition condition = lock.newCondition();

// 在一个线程中
lock.lock();
try {
    condition.await();
} catch (InterruptedException e) {
    e.printStackTrace();
} finally {
    lock.unlock();
}

// 在另一个线程中
lock.lock();
try {
    condition.signal();
} finally {
    lock.unlock();
}

CountDownLatch： CountDownLatch 是一个同步辅助类，它允许一个或多个线程等待直到一组操作完成。线程可以调用 await() 方法等待，其他线程可以调用 countDown() 方法减少计数器。当计数器减到0时，等待的线程会被唤醒。

示例：

CountDownLatch latch = new CountDownLatch(1);

// 在一个线程中
try {
    latch.await();
} catch (InterruptedException e) {
    e.printStackTrace();
}

// 在另一个线程中
latch.countDown();

CyclicBarrier： CyclicBarrier 是一个同步辅助类，它允许一组线程互相等待，直到所有线程都准备好继续执行。线程可以调用 await() 方法等待，当所有线程都调用了 await() 方法后，所有线程会被同时唤醒。

示例：

CyclicBarrier barrier = new CyclicBarrier(2);

// 在一个线程中
try {
    barrier.await();
} catch (InterruptedException | BrokenBarrierException e) {
    e.printStackTrace();
}

// 在另一个线程中
try {
    barrier.await();
} catch (InterruptedException | BrokenBarrierException e) {
    e.printStackTrace();
}

Semaphore： Semaphore 是一个计数信号量，它可以用来控制同时访问特定资源的线程数量。线程可以通过调用 acquire() 方法获取许可，如果没有可用的许可，线程将被阻塞。线程可以通过调用 release() 方法释放许可。

示例：

Semaphore semaphore = new Semaphore(1);

// 在一个线程中
try {
    semaphore.acquire();
} catch (InterruptedException e) {
    e.printStackTrace();
}

// 在另一个线程中
semaphore.release();

这些方法可以根据不同的场景和需求选择使用，以实现线程间的有效通信。

亿速云「云服务器」，即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘，价格低至29元/月。点击查看>>

向AI问一下细节

Java多线程间如何通信

猜你喜欢

最新资讯

相关推荐

开发者交流群：

相关标签