Java中如何实现多线程同步

在Java中，实现多线程同步的方法主要有以下几种：

1. 使用synchronized关键字：
   • 同步方法：在方法声明前加上synchronized关键字，使得同一时间只有一个线程可以访问该方法。
   • 同步代码块：使用synchronized关键字修饰一个代码块，指定一个锁对象，使得同一时间只有一个线程可以执行该代码块。

public class SynchronizedExample {
    public synchronized void synchronizedMethod() {
        // 同步方法
    }

    public void synchronizedBlock() {
        synchronized (this) {
            // 同步代码块
        }
    }
}

2. 使用ReentrantLock类： ReentrantLock类提供了比synchronized更灵活的锁定机制。通过lock()和unlock()方法来显式地获取和释放锁。

import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

public class ReentrantLockExample {
    private final Lock lock = new ReentrantLock();

    public void lockMethod() {
        lock.lock();
        try {
            // 同步代码块
        } finally {
            lock.unlock();
        }
    }
}

3. 使用Semaphore类： Semaphore类是一个计数信号量，可以用来控制同时访问某一资源的线程数量。

import java.util.concurrent.Semaphore;

public class SemaphoreExample {
    private final Semaphore semaphore = new Semaphore(1);

    public void semaphoreMethod() {
        try {
            semaphore.acquire();
            // 同步代码块
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            semaphore.release();
        }
    }
}

4. 使用CountDownLatch类： CountDownLatch类允许一个或多个线程等待其他线程完成操作后再继续执行。

import java.util.concurrent.CountDownLatch;

public class CountDownLatchExample {
    private final CountDownLatch latch = new CountDownLatch(1);

    public void countDownLatchMethod() {
        try {
            latch.await();
            // 同步代码块
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

    public void countDownLatchCountDown() {
        latch.countDown();
    }
}

5. 使用CyclicBarrier类： CyclicBarrier类允许一组线程互相等待，直到所有线程都准备好继续执行。

import java.util.concurrent.CyclicBarrier;

public class CyclicBarrierExample {
    private final CyclicBarrier barrier = new CyclicBarrier(2);

    public void cyclicBarrierMethod() {
        try {
            barrier.await();
            // 同步代码块
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

这些方法可以根据具体需求选择使用，以实现多线程同步。