线程通讯揭秘：深入解析共享内存与消息传递

2024-01-17 21:19:55

线程作为操作系统中独立的执行单元，在多线程编程中，多个线程协调合作是实现高并发高性能程序的关键。然而，线程之间的通讯是协调协作的基石，它决定了线程如何共享数据、同步执行。

共享内存

共享内存是线程通讯最基本的方式，通过在多个线程之间共享一块内存区域来实现数据的交换。每个线程都可以读写共享内存中的数据，从而实现数据的同步和交换。

public class SharedMemoryExample {

    private static int sharedValue = 0;

    public static void main(String[] args) throws InterruptedException {
        Thread thread1 = new Thread(() -> {
            for (int i = 0; i < 1000; i++) {
                sharedValue++;
            }
        });

        Thread thread2 = new Thread(() -> {
            for (int i = 0; i < 1000; i++) {
                sharedValue++;
            }
        });

        thread1.start();
        thread2.start();
        thread1.join();
        thread2.join();

        System.out.println("Final shared value: " + sharedValue);
    }
}

消息传递

消息传递是一种更复杂的线程通讯方式，它通过消息队列或管道来传递消息，线程之间通过发送和接收消息进行通讯。消息队列是存储消息的缓冲区，每个线程都可以向消息队列中发送或从消息队列中接收消息。

public class MessagePassingExample {

    private static BlockingQueue<Message> messageQueue = new ArrayBlockingQueue<>(100);

    public static void main(String[] args) throws InterruptedException {
        Thread thread1 = new Thread(() -> {
            for (int i = 0; i < 1000; i++) {
                messageQueue.put(new Message(i, "Thread 1"));
            }
        });

        Thread thread2 = new Thread(() -> {
            for (int i = 0; i < 1000; i++) {
                Message message = messageQueue.take();
                System.out.println(message);
            }
        });

        thread1.start();
        thread2.start();
        thread1.join();
        thread2.join();
    }

    private static class Message {
        private int value;
        private String threadName;

        public Message(int value, String threadName) {
            this.value = value;
            this.threadName = threadName;
        }

        @Override
        public String toString() {
            return "Message [value=" + value + ", threadName=" + threadName + "]";
        }
    }
}