大家好我是锋哥。今天分享关于【Java高频面试题Java线程之间如何通信】面试题 。希望对大家有帮助Java高频面试题Java线程之间如何通信在Java中多线程编程是一个非常常见的需求。通常我们需要多个线程协同工作它们可能需要共享资源、传递信息或者在某些条件下相互等待。这就涉及到线程之间的通信。Java为此提供了几种机制使得线程可以相互交互和同步。本文将探讨Java线程之间的通信方式。1. 使用wait()和notify()方法wait()、notify()和notifyAll()是Object类中的三个方法它们通常用于线程之间的协作。它们能够在多线程之间进行有效的同步和通信。我们可以通过这几个方法来让线程在满足某些条件时进行通信。wait()调用该方法的线程会释放当前持有的锁并进入等待状态直到另一个线程调用该对象的notify()或notifyAll()方法。notify()唤醒在当前对象监视器上等待的一个线程。notifyAll()唤醒在当前对象监视器上等待的所有线程。这三个方法必须在同步方法或同步块即在synchronized块内中调用因为它们涉及到锁的释放和获取。示例生产者-消费者模型在生产者-消费者问题中生产者线程生产数据并放入缓冲区消费者线程从缓冲区中获取数据并处理。这两个线程通过wait()和notify()方法进行通信确保生产者在缓冲区满时等待消费者在缓冲区空时等待。class Buffer { private int data -1; public synchronized void produce(int value) throws InterruptedException { while (data ! -1) { wait(); // 等待消费者消费 } data value; System.out.println(Produced: value); notify(); // 唤醒消费者 } public synchronized int consume() throws InterruptedException { while (data -1) { wait(); // 等待生产者生产 } int value data; data -1; System.out.println(Consumed: value); notify(); // 唤醒生产者 return value; } } public class ProducerConsumer { public static void main(String[] args) { Buffer buffer new Buffer(); Thread producer new Thread(() - { try { for (int i 0; i 5; i) { buffer.produce(i); Thread.sleep(1000); } } catch (InterruptedException e) { e.printStackTrace(); } }); Thread consumer new Thread(() - { try { for (int i 0; i 5; i) { buffer.consume(); Thread.sleep(1500); } } catch (InterruptedException e) { e.printStackTrace(); } }); producer.start(); consumer.start(); } }在上面的示例中produce()方法和consume()方法中都包含了wait()和notify()的使用。生产者生产数据时会等待消费者消费消费者消费数据时会等待生产者生产。2. 使用BlockingQueueBlockingQueue是Java并发包java.util.concurrent中的一个接口它提供了一种线程安全的阻塞队列用于在生产者和消费者线程之间传递数据。BlockingQueue提供了put()和take()方法来实现线程通信。put()如果队列已满生产者线程会被阻塞直到队列有空位。take()如果队列为空消费者线程会被阻塞直到队列中有元素。BlockingQueue的实现类如ArrayBlockingQueue、LinkedBlockingQueue等已经内置了wait()和notify()机制使用起来更加方便。示例使用BlockingQueueimport java.util.concurrent.*; public class ProducerConsumerBlockingQueue { public static void main(String[] args) throws InterruptedException { BlockingQueueInteger queue new ArrayBlockingQueue(1); // 容量为1的阻塞队列 Thread producer new Thread(() - { try { for (int i 0; i 5; i) { queue.put(i); // 生产者放入数据 System.out.println(Produced: i); Thread.sleep(1000); } } catch (InterruptedException e) { e.printStackTrace(); } }); Thread consumer new Thread(() - { try { for (int i 0; i 5; i) { int value queue.take(); // 消费者获取数据 System.out.println(Consumed: value); Thread.sleep(1500); } } catch (InterruptedException e) { e.printStackTrace(); } }); producer.start(); consumer.start(); producer.join(); consumer.join(); } }在这个例子中我们使用了BlockingQueue的put()和take()方法来进行线程间的通信避免了直接使用wait()和notify()使得代码更加简洁和安全。3. 使用CountDownLatchCountDownLatch是一个同步工具类用于让一个或多个线程等待直到其他线程的操作完成。它通过一个计数器实现调用countDown()方法会减少计数器的值而await()方法会让线程等待直到计数器的值为零。CountDownLatch的常见用途之一是让多个线程等待某个线程完成操作后再继续执行。示例使用CountDownLatchimport java.util.concurrent.*; public class CountDownLatchExample { public static void main(String[] args) throws InterruptedException { CountDownLatch latch new CountDownLatch(2); Thread worker1 new Thread(() - { try { System.out.println(Worker 1 is working...); Thread.sleep(2000); System.out.println(Worker 1 finished); latch.countDown(); } catch (InterruptedException e) { e.printStackTrace(); } }); Thread worker2 new Thread(() - { try { System.out.println(Worker 2 is working...); Thread.sleep(1000); System.out.println(Worker 2 finished); latch.countDown(); } catch (InterruptedException e) { e.printStackTrace(); } }); worker1.start(); worker2.start(); latch.await(); // 等待两个线程完成 System.out.println(Both workers finished, main thread proceeds.); } }在这个例子中main线程会等待两个工作线程完成任务后才继续执行。通过CountDownLatch实现了线程之间的同步。4. 使用CyclicBarrierCyclicBarrier是另一个同步工具类允许一组线程互相等待直到所有线程都到达某个公共屏障点。与CountDownLatch不同的是CyclicBarrier可以被重用。示例使用CyclicBarrierimport java.util.concurrent.*; public class CyclicBarrierExample { public static void main(String[] args) throws InterruptedException { CyclicBarrier barrier new CyclicBarrier(3, () - System.out.println(All threads reached barrier, proceeding)); Thread t1 new Thread(() - { try { Thread.sleep(1000); System.out.println(Thread 1 arrived); barrier.await(); } catch (InterruptedException | BrokenBarrierException e) { e.printStackTrace(); } }); Thread t2 new Thread(() - { try { Thread.sleep(2000); System.out.println(Thread 2 arrived); barrier.await(); } catch (InterruptedException | BrokenBarrierException e) { e.printStackTrace(); } }); Thread t3 new Thread(() - { try { Thread.sleep(3000); System.out.println(Thread 3 arrived); barrier.await(); } catch (InterruptedException | BrokenBarrierException e) { e.printStackTrace(); } }); t1.start(); t2.start(); t3.start(); } }在上面的例子中CyclicBarrier会等待三个线程都到达屏障点然后执行屏障后的操作。最后总结下哈Java提供了多种线程通信机制包括传统的wait()和notify()以及现代的并发工具类BlockingQueue、CountDownLatch和CyclicBarrier等。每种机制都有其特定的应用场景选择合适的通信方式可以有效地提高程序的效率和可维护性。在实际开发中根据需求和代码复杂度合理选择线程通信机制能够使得多线程协作更加高效和稳定。