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

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

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

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

2. 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();         }     } } 

3. 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         // 同步执行的代码     } } 

4. 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();         }     } } 

5. 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多线程任务的同步执行。