java 高并发

// 高并发编程中，线程安全是一个非常重要的概念。下面是一个使用 Java 的并发工具类来实现高并发场景下的线程安全计数器的示例。

import java.util.concurrent.atomic.AtomicInteger;

public class ConcurrentCounter {
    // 使用 AtomicInteger 来保证计数操作的原子性
    private AtomicInteger count = new AtomicInteger(0);

    // 线程安全的增加计数方法
    public void increment() {
        count.incrementAndGet();
    }

    // 获取当前计数
    public int getCount() {
        return count.get();
    }

    public static void main(String[] args) throws InterruptedException {
        // 创建一个共享的计数器实例
        ConcurrentCounter counter = new ConcurrentCounter();

        // 创建多个线程来模拟高并发场景
        Thread[] threads = new Thread[100];
        for (int i = 0; i < threads.length; i++) {
            threads[i] = new Thread(() -> {
                for (int j = 0; j < 1000; j++) {
                    counter.increment();
                }
            });
        }

        // 启动所有线程
        for (Thread thread : threads) {
            thread.start();
        }

        // 等待所有线程执行完毕
        for (Thread thread : threads) {
            thread.join();
        }

        // 输出最终的计数值
        System.out.println("Final count: " + counter.getCount());
    }
}

解释说明：

• AtomicInteger：AtomicInteger 是 Java 并发包中的一个类，它提供了原子操作，可以确保在多线程环境下对整数的操作是线程安全的。
• incrementAndGet()：这是一个原子操作，它可以安全地将 count 的值加 1，并返回新的值。
• getCount()：用于获取当前的计数值。
• 多线程模拟：通过创建多个线程来模拟高并发场景，每个线程都会调用 increment() 方法多次，以验证计数器的线程安全性。
• 线程同步：使用 join() 方法确保主线程等待所有子线程执行完毕后再输出结果，保证结果的准确性。