如何解决 Java Runnable 线程同步问题

在Java中，当多个线程访问共享资源时，可能会出现线程同步问题

1. 使用synchronized关键字：

   在需要同步的方法或代码块上添加synchronized关键字。这将确保一次只有一个线程可以执行该方法或代码块。

   public class MyRunnable implements Runnable {
       private final Object lock = new Object();
   
       @Override
       public void run() {
           synchronized (lock) {
               // 访问共享资源的代码
           }
       }
   }
   

2. 使用Lock接口和ReentrantLock类：

   Java提供了Lock接口和ReentrantLock类来实现更灵活的线程同步。

   import java.util.concurrent.locks.Lock;
   import java.util.concurrent.locks.ReentrantLock;
   
   public class MyRunnable implements Runnable {
       private final Lock lock = new ReentrantLock();
   
       @Override
       public void run() {
           lock.lock();
           try {
               // 访问共享资源的代码
           } finally {
               lock.unlock();
           }
       }
   }
   

3. 使用volatile关键字：

   当一个变量被声明为volatile时，它将确保所有线程都能看到最新的值，从而避免线程同步问题。

   public class MyRunnable implements Runnable {
       private volatile int sharedResource;
   
       @Override
       public void run() {
           // 访问共享资源的代码
       }
   }
   

4. 使用原子类：

   Java提供了一些原子类，如AtomicInteger、AtomicLong等，它们可以在多线程环境下保证原子性操作。

   import java.util.concurrent.atomic.AtomicInteger;
   
   public class MyRunnable implements Runnable {
       private final AtomicInteger sharedResource = new AtomicInteger(0);
   
       @Override
       public void run() {
           // 访问共享资源的代码
       }
   }
   

5. 使用BlockingQueue：

   当多个线程需要访问共享资源时，可以使用BlockingQueue来实现线程安全的队列操作。

   import java.util.concurrent.BlockingQueue;
   import java.util.concurrent.LinkedBlockingQueue;
   
   public class MyRunnable implements Runnable {
       private final BlockingQueue<Integer> queue = new LinkedBlockingQueue<>();
   
       @Override
       public void run() {
           try {
               int item = queue.take(); // 获取队列中的元素，若队列为空则阻塞
               // 处理元素的代码
           } catch (InterruptedException e) {
               // 处理异常
           }
       }
   }
   

根据具体场景和需求，可以选择合适的同步方法来解决Java Runnable线程同步问题。