Java多线程同步控制问题实例

原创叁歲伎倆 2024-11-25 18:30 39阅读 0赞

在Java多线程编程中，常见的同步控制手段包括：synchronized关键字、wait/notify方法、CountDownLatch、Semaphore等。

下面以一个简单的生产者消费者问题为例，展示如何使用synchronized关键字进行同步控制：

```java
// 创建共享资源
 class Stock {
     int count = 0;
     // synchronized关键字确保同一时间只有一个线程可以访问这个类的方法
     synchronized void produce() {
         count++;
         System.out.println("Producer produced: " + count);
     }
 
     synchronized void consume() {
         if (count > 0) {
             count--;
             System.out.println("Consumer consumed: " + count);
         } else {
             System.out.println("Stock is empty, cannot consume.");
         }
     }
 }

// 创建线程
public class MultiThreadExample {
    public static void main(String[] args) {
        // 创建共享资源对象
        Stock stock = new Stock();

// 生产者线程
        Thread producer = new Thread(() -> {
            while (true) {  // 模拟无尽的生产
                stock.produce();
                try {
                    // 线程休眠，模拟耗时操作
                    Thread.sleep(1000);  // 假设生产每秒一次
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }));

// 消费者线程
        Thread consumer = new Thread(() -> {
            while (true) {  // 模拟无尽的消费
                stock.consume();
                try {
                    // 线程休眠，模拟耗时操作
                    Thread.sleep(1000);  // 假设消费每秒一次
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }));

// 启动线程
        producer.start();
        consumer.start();

// 关闭生产者和消费者线程
        producer.join();  // 等待生产者线程结束
        consumer.join();  // 等待消费者线程结束

System.out.println("Stock synchronization completed.");
    }
}
```

在这个例子中，我们通过synchronized关键字对`Stock`类的`produce`和`consume`方法进行了同步控制。这样就确保了在同一时间只有一个线程可以访问这些方法，从而保证了多线程环境下的数据一致性。