Java多线程并发控制不当问题示例

原创 Myth丶恋晨 2024-10-11 16:42 72阅读 0赞

在Java多线程编程中，如果并发控制不当，可能会出现各种问题。这里举几个常见的例子：

1. **数据竞争（Race Condition）**：
   如果两个或更多的线程同时访问和修改一个共享资源（如变量、数组等），就可能出现问题。
   示例：
   ```java
   class Counter {
       int count = 0;

synchronized void increment() {
           count++;
           notifyAll(); // 向等待的线程发出信号
       }

// 线程A: 调用increment()
       // 线程B: 调用decrement()
       synchronized void decrement() {
           count--;
           if (count <= 0) { // 如果计数为负，则唤醒所有等待的线程
               while (count < 0) {
                   try {
                       wait();
                   } catch (InterruptedException e) {
                       e.printStackTrace();
                   }
               }
               count = 0; // 计数重置为0
           }
           notifyAll(); // 向等待的线程发出信号
       }
   }

class ThreadExample extends Thread {
       private Counter counter;

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

@Override
       public void run() {
           try {
               counter.increment(); // 线程A: 调用increment()
               System.out.println("增1后计数为：" + counter.count); // 输出计数

Thread.sleep(2000); // 暂停2秒，以演示线程A与B之间的交互

counter.decrement(); // 线程B: 调用decrement()
               System.out.println("减1后计数为：" + counter.count)); // 输出计数
           } catch (InterruptedException e) {
               e.printStackTrace();
           }
       }
   }

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

ThreadExample threadA = new ThreadExample(counter);
           ThreadExample threadB = new ThreadExample(counter);

// 启动线程
           threadA.start();
           threadB.start();
       }
   }
```
在这个例子中，两个线程（threadA和threadB）同时对共享的counter计数进行操作。这可能会导致数据竞争问题，如计数不准确或出现负数。

要解决这个问题，可以使用Java的synchronized关键字来同步访问共享资源。在上述示例中，可以在increment和decrement方法上加锁，确保同一时间只有一个线程能够执行这些方法。