并发控制不当：Java多线程同步问题实例

原创以你之姓@ 2024-10-17 09:09 54阅读 0赞

在Java多线程编程中，如果并发控制不当，很容易出现数据一致性问题。以下是一些具体的实例：

1. **共享变量修改**：
   ```java
   class Counter {
       int count = 0;
       // 线程1: 增加count
       synchronized void increment() {
           count++;
       }
       // 线程2：获取并打印count
       synchronized void printCount() {
           System.out.println("Current count: " + count);
       }
   }

class ThreadExample extends Thread {
       Counter counter;

public ThreadExample(Counter c) {
           this.counter = c;
           start();
       }

@Override
       public void run() {
           // 线程1：增加count
           counter.increment();

// 等待一段时间（模拟耗时操作）...
           try {
               Thread.sleep(2000);  // 模拟耗时，这里设置为2秒
           } catch (InterruptedException e) {
               e.printStackTrace();
           }

// 线程1：打印修改后的count
           counter.printCount();
       }
   }

public class Main {
       public static void main(String[] args) {
           Counter counter = new Counter();

ThreadExample thread1 = new ThreadExample(counter);
           ThreadExample thread2 = new ThreadExample(counter);

thread1.start();  // 开始线程1
           thread2.start();  // 开始线程2

try {
               // 线程1和线程2等待所有任务完成
               thread1.join();
               thread2.join();
           } catch (InterruptedException e) {
               e.printStackTrace();
           }

System.out.println("All threads completed.");
       }
   }
```
在这个例子中，我们有两个并发线程（`thread1` 和 `thread2`），它们共享同一个计数器。

线程1增加计数器，然后等待一段时间后打印更新后的计数器。

线程2在开始时就直接获取并打印当前的计数器。

问题在于两个线程同时修改计数器。这会导致数据不一致，因为只有一个锁（`synchronized`）来控制对计数器的访问。

解决这个问题的方法是使用更严格的同步机制，比如`ReentrantLock`或者使用Java 1.5及更高版本提供的并发工具类（如`AtomicInteger`或`ConcurrentHashMap`）。