Java多线程同步挑战：实例解析

原创朱雀 2024-11-26 09:27 46阅读 0赞

在Java编程中，多线程同步是一个关键的概念，用于控制多个线程对共享资源的访问。以下是几个实例来解析这个概念：

1. **synchronized关键字**：
   ```java
   // 假设有一个共享变量count
   synchronized (count) {
       count++;  // 线程A更新count
       try {
           Thread.sleep(500);  // 线程A休眠
       } catch (InterruptedException e) {
           e.printStackTrace();
       }
       // 线程B在同一个synchronized块中获取锁并更新count
   }
   ```
2. **wait()与notify()**：
   ```java
   // 假设有一个阻塞队列
   class Queue {
       private int data;
       private boolean isEmpty = true;

synchronized void enqueue(int value) {
           data = value;
           isEmpty = false;
           notifyAll();  // 唤醒所有等待的线程
       }

synchronized int dequeue() throws InterruptedException {
           while (isEmpty) {
               wait();  // 线程A进入等待状态
           }
           int value = data;  // 获取队列中的数据
           data = 0;
           isEmpty = true;
           notifyAll();  // 唤醒所有等待的线程
           return value;
       }
   }

class ThreadExample extends Thread {
       private Queue queue;

public ThreadExample(Queue queue) {
           this.queue = queue;
       }

@Override
       public void run() {
           try {
               queue.enqueue(1);  // A线程向队列中添加数据
               System.out.println("A thread: Dequeued data - " + queue.dequeue());  // B线程从队列中获取并打印数据

// 在这里，你可以设计多线程的同步逻辑，如条件等待、锁竞争等。
           } catch (InterruptedException e) {
               e.printStackTrace();
           }
       }
   }

// 创建一个阻塞队列
   Queue queue = new Queue();

// 启动两个线程：A和B
   ThreadExample threadA = new ThreadExample(queue);
   ThreadExample threadB = new ThreadExample(queue);

threadA.start();  // A线程启动
   threadB.start();  // B线程启动

```
在这个例子中，线程A和线程B分别向队列添加数据（enqueue）和从队列获取数据（dequeue）。通过wait()与notify()的交互，实现了多线程同步。

这个例子展示了Java多线程编程中的同步机制，实际上在实际项目中会更复杂，包括锁竞争、条件等待等。