性能优化：Java多线程并发控制示例

原创川长思鸟来 2024-09-12 20:42 105阅读 0赞

在Java中，多线程可以显著提高程序的执行效率。但是，如果不正确地管理并发，可能会导致数据不一致、死锁等问题。

这里我们以一个简单的生产者消费者模型为例，展示如何使用synchronized关键字来正确地管理并发：

```java
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.CyclicBarrier;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.TimeUnit;

public class MultiThreadedExample {

private final BlockingQueue<Integer> queue = new LinkedBlockingQueue<>(10);

public void producer() throws InterruptedException {
        CyclicBarrier barrier = new CyclicBarrier(2, () -> System.out.println("Producer reached barrier"));;
        for (int i = 0; i < 10; i++) {
            barrier.await(); // Wait until both producers have reached the barrier
            queue.put(i);
        }
    }

public void consumer() throws InterruptedException, ExecutionException {
        while (!queue.isEmpty()) {
            int number = queue.take();
            System.out.println("Consumer received " + number);
        }
    }

public static void main(String[] args) {
        MultiThreadedExample example = new MultiThreadedExample();
        new Thread(example::producer).start();
        new Thread(example::consumer).start();
    }
}
```

在这个示例中，我们创建了一个生产者（producer）和一个消费者（consumer）。生产者向队列（blocking queue）添加元素，而消费者则从队列中取出并处理这些元素。

通过这种方式，多线程可以并发地执行任务，提高程序的效率。同时，通过synchronized关键字管理同步，我们可以避免数据不一致等问题。