理解和避免Java中的并发问题示例

原创谁践踏了优雅 2024-11-15 08:06 9阅读 0赞

在Java中，并发问题主要涉及到线程安全、死锁、资源泄露等问题。下面我们将通过一些实例来理解并避免这些问题。

1. **线程安全：**当一个方法被多个线程同时访问时，需要保证数据的一致性。

示例：
   ```java
   // 线程不安全的计数器
   private int counter = 0;

public synchronized void incrementCounter() {
       counter++;
   }

public synchronized int getCounter() {
       return counter;
   }
   ```

2. **死锁：**当两个或更多的线程互相等待对方释放资源时，就会发生死锁。

示例：
   ```java
   // 线程1: 期望获得线程2的资源
   private Thread thread2 = new Thread("Thread2"));

public void startThread2() {
       thread2.start();
   }

// 线程2: 期望获得线程1的资源
   public class WaitingThread implements Runnable {
       private Thread thread1;

public void setThread1(Thread thread1) {
           this.thread1 = thread1;
       }

@Override
       public void run() {
           try {
               // 线程2模拟等待资源
               System.out.println("Waiting for resource from " + thread1.getName());
               Thread.sleep(5000);  // 模拟等待时间

// 线程2完成资源请求
               System.out.println("Received resource from " + thread1.getName());

} catch (InterruptedException e) {
               e.printStackTrace();
           }
       }
   }

public void startThread1() {
       WaitingThread wt = new WaitingThread();
       wt.setThread1(thread2);
       thread1 = new Thread(wt);
       thread1.start();
   }

public static void main(String[] args) {
       // 创建线程
       Thread thread1 = new Thread("Thread1");
       Thread thread2 = new Thread("Thread2");

// 启动线程
       thread1.start();
       thread2.start();

// 线程执行完后的处理
       try {
           // 等待所有线程执行完毕
           thread1.join();
           thread2.join();

System.out.println("All threads finished execution.");

} catch (InterruptedException e) {
           e.printStackTrace();
       }
   }
   ```

在这个例子中，线程1（Thread1）和线程2（Thread2）互相等待对方释放资源。结果会导致死锁。

通过理解和避免这些并发问题，我们可以编写出更加高效、稳定的Java程序。