你如何理解并发编程在Java中的体现？请举一个例子

原创 r囧r小猫 2025-03-21 15:15 41阅读 0赞

并发编程在Java中主要体现在多线程的创建和执行上。每个线程就像是操作系统调度的一个独立任务。

以下是一个简单的Java并发编程例子，这里我们将通过实现一个生产者-消费者模型来展示：

```java
import java.util.concurrent.*;

public class ConcurrentExample {
    private static final int PRODUCER_COUNT = 2;
    private static final int CONSUMER_COUNT = 1;
    private static final int ITEMS_PER_PRODUCER = 50;

public static void main(String[] args) throws InterruptedException, ExecutionException {
        // 创建生产者线程
        ExecutorService producerExecutor = Executors.newFixedThreadPool(PRODUCER_COUNT);
        List<Future<Item>> producedItemsFutureList = new ArrayList<>(PRODUCER_COUNT);

for (int i = 0; i < PRODUCER_COUNT; i++) {
            Future<Item> producedItemFuture = producerExecutor.submit(() -> produceItem(ITEMS_PER_PRODUCER)));
            producedItemsFutureList.add(producedItemFuture);
        }

// 等待所有生产者线程完成
        producerExecutor.shutdown();
        producerExecutor.awaitTermination(Long.MAX_VALUE, TimeUnit.MILLISECONDS));

// 创建消费者线程
        ExecutorService consumerExecutor = Executors.newFixedThreadPool(CONSUMER_COUNT));
        ConsumerThread consumerThread = new ConsumerThread(producedItemsFutureList);
        consumerExecutor.submit(consumerThread);

// 等待消费者线程完成
        consumerExecutor.shutdown();
        consumerExecutor.awaitTermination(Long.MAX_VALUE, TimeUnit.MILLISECONDS));
    }

private static Item produceItem(int itemsPerProducer) {
        // 这里只是一个模拟生产过程的简单操作，实际生产可能涉及到数据库操作、网络通信等多种复杂行为。
        return new Item(itemsPerProducer);
    }
}
```

在这个例子中，我们创建了两个线程池：一个用于生产物品（模拟），另一个用于消费这些物品。通过多线程并发执行，我们可以实现更高效的资源利用。