java多线程任务如何同步执行

在Java中，有多种方法可以实现多线程任务的同步执行。以下是一些常用的方法：

synchronized关键字：synchronized关键字可以用于修饰方法或者代码块，确保同一时间只有一个线程能够访问被保护的资源。当一个线程进入synchronized修饰的方法或代码块时，其他线程需要等待该线程执行完毕后才能访问。

public synchronized void syncMethod() {    // 同步执行的代码}public void anotherMethod() {    synchronized (this) {        // 同步执行的代码    }}

ReentrantLock类：ReentrantLock是一个可重入的互斥锁，它提供了与synchronized相同的功能，但更加灵活。通过使用ReentrantLock，可以实现更加精细的线程同步控制。

import java.util.concurrent.locks.ReentrantLock;public class MyClass {    private final ReentrantLock lock = new ReentrantLock();    public void syncMethod() {        lock.lock();        try {            // 同步执行的代码        } finally {            lock.unlock();        }    }}

CountDownLatch类：CountDownLatch是一个同步辅助类，它允许一个或多个线程等待直到一组操作完成。通过使用CountDownLatch，可以实现线程间的协同工作。

import java.util.concurrent.CountDownLatch;public class MyClass {    private final CountDownLatch latch = new CountDownLatch(1);    public void syncMethod() {        // 执行同步任务的代码        latch.countDown(); // 减少计数器    }    public void anotherMethod() throws InterruptedException {        latch.await(); // 等待计数器变为0        // 同步执行的代码    }}

CyclicBarrier类：CyclicBarrier是一个循环栅栏，它允许一组线程相互等待，直到所有线程都准备好继续执行。通过使用CyclicBarrier，可以实现线程间的协同工作。

import java.util.concurrent.CyclicBarrier;public class MyClass {    private final CyclicBarrier barrier = new CyclicBarrier(2);    public void syncMethod() {        try {            barrier.await(); // 等待其他线程            // 同步执行的代码        } catch (InterruptedException | BrokenBarrierException e) {            e.printStackTrace();        }    }    public void anotherMethod() {        try {            barrier.await(); // 等待其他线程            // 同步执行的代码        } catch (InterruptedException | BrokenBarrierException e) {            e.printStackTrace();        }    }}

Semaphore类：Semaphore是一个计数信号量，它允许一定数量的线程访问共享资源。通过使用Semaphore，可以实现线程间的同步控制。

import java.util.concurrent.Semaphore;public class MyClass {    private final Semaphore semaphore = new Semaphore(1);    public void syncMethod() {        try {            semaphore.acquire(); // 获取许可            // 同步执行的代码        } catch (InterruptedException e) {            e.printStackTrace();        } finally {            semaphore.release(); // 释放许可        }    }}

根据具体的需求和场景，可以选择合适的方法来实现Java多线程任务的同步执行。