Java并发计数器：两种线程间变量同步与通信策略

class CounterExample {
    int x = 5; // 共享字段

    void example() {
        new Thread(this::incrementTask).start();
        new Thread(this::printTask).start();
    }

    void incrementTask() {
        try {
            Thread.sleep(1000L); // 模拟耗时操作
            x += 5;
            System.out.println("Incremented x!");
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
    }

    void printTask() {
        try {
            Thread.sleep(1500L); // 模拟耗时操作
            // 在没有同步机制的情况下，这里打印的x可能仍是5，而不是10
            System.out.println("x is: " + x);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
    }

    public static void main(String[] args) {
        new CounterExample().example();
    }
}

import java.util.concurrent.atomic.AtomicInteger;

class AtomicCounterExample {
    AtomicInteger x = new AtomicInteger(5); // 使用AtomicInteger作为共享计数器

    void example() {
        new Thread(this::incrementTask).start();
        new Thread(this::printTask).start();
    }

    void incrementTask() {
        try {
            Thread.sleep(1000L);
            x.addAndGet(5); // 原子地增加值并获取新值
            System.out.println("Incremented x!");
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
    }

    void printTask() {
        try {
            Thread.sleep(1500L);
            System.out.println("x is: " + x.get()); // 获取当前值，保证可见性
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
    }

    public static void main(String[] args) {
        new AtomicCounterExample().example();
    }
}

import java.util.concurrent.LinkedBlockingQueue;

class MessageBusExample {
    // 创建一个容量为100的阻塞队列作为消息通道
    var queue = new LinkedBlockingQueue<Integer>(100);

    void example() {
        new Thread(this::producerTask).start(); // 生产者线程
        new Thread(this::consumerTask).start(); // 消费者线程
    }

    void producerTask() {
        try {
            for (int i = 0; i < 1000; i++) {
                queue.put(i); // 将数据放入队列，如果队列满则阻塞
                System.out.println("Added to queue: " + i);
                Thread.sleep(50L); // 模拟生产数据的间隔
            }
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
    }

    void consumerTask() {
        try {
            while (true) {
                int v = queue.take(); // 从队列中取出数据，如果队列空则阻塞
                System.out.println("Retrieved: " + v);
                if (v % 10 == 0) {
                    System.out.println("Value " + v + " is divisible by 10, waiting a while.");
                    Thread.sleep(200L); // 模拟处理特定数据时的耗时
                }
            }
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
    }

    public static void main(String[] args) {
        new MessageBusExample().example();
    }
}