当前位置：首页 > Java

Java线程如何通讯

2026-02-05 02:20:41Java

Java线程通讯方法

Java线程通讯主要通过共享内存和消息传递实现，以下是几种常见方式：

共享变量

使用synchronized关键字保护共享变量，结合wait()和notify()机制：

class SharedObject {
    private boolean flag = false;

    public synchronized void waitForFlag() throws InterruptedException {
        while(!flag) {
            wait();
        }
    }

    public synchronized void setFlag() {
        flag = true;
        notifyAll();
    }
}

BlockingQueue

利用线程安全的阻塞队列实现生产者-消费者模式：

BlockingQueue<String> queue = new LinkedBlockingQueue<>();

// 生产者线程
queue.put("message");

// 消费者线程
String message = queue.take();

CountDownLatch

适用于一次性线程同步场景：

CountDownLatch latch = new CountDownLatch(3);

// 工作线程
latch.countDown();

// 主线程
latch.await();

CyclicBarrier

可重复使用的线程屏障：

CyclicBarrier barrier = new CyclicBarrier(3, () -> 
    System.out.println("All threads reached barrier"));

// 工作线程
barrier.await();

Exchanger

两个线程间交换数据：

Exchanger<String> exchanger = new Exchanger<>();

// 线程A
String dataA = exchanger.exchange("Data from A");

// 线程B
String dataB = exchanger.exchange("Data from B");

Semaphore

控制资源访问的并发数：

Semaphore semaphore = new Semaphore(5);

// 线程获取许可
semaphore.acquire();
try {
    // 访问共享资源
} finally {
    semaphore.release();
}

Future和Callable

获取线程执行结果：

ExecutorService executor = Executors.newSingleThreadExecutor();
Future<String> future = executor.submit(() -> "Result");

String result = future.get();

PipedStream

线程间通过管道传输数据：

PipedInputStream in = new PipedInputStream();
PipedOutputStream out = new PipedOutputStream(in);

// 写线程
out.write("data".getBytes());

// 读线程
int data = in.read();

选择通讯方式时应考虑具体场景，对于简单同步需求可使用synchronized，复杂场景建议使用java.util.concurrent包中的高级工具类。

Java线程如何通讯