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多線程任務的同步執行。