Java?CyclicBarrier錯誤使用的實例

更新時間：2025年01月26日 10:35:26 作者：學亮編程手記

文章描述了一個Java程序使用CyclicBarrier實現(xiàn)兩個線程交替打印字母和數(shù)字時遇到的問題,由于線程執(zhí)行順序不當,導致輸出結(jié)果與預期不符,通過調(diào)整線程的等待和打印順序,解決了問題,文章還提供了一個控制流圖來詳細解釋修改前后的程序邏輯

Java CyclicBarrier錯誤使用

錯誤代碼示例

import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;

public class AlternatePrintCyclicBarrier {

    private static final CyclicBarrier barrier = new CyclicBarrier(2);

    public static void main(String[] args) {
        String letters = "abcd";
        String numbers = "1234";

        Thread letterThread = new Thread(() -> {
            for (char letter : letters.toCharArray()) {
                try {
                    System.out.print(letter);
                    barrier.await(); // 等待另一個線程
                } catch (InterruptedException | BrokenBarrierException e) {
                    Thread.currentThread().interrupt();
                }
            }
        });

        Thread numberThread = new Thread(() -> {
            for (char number : numbers.toCharArray()) {
                try {
                    barrier.await(); // 等待字母線程
                    System.out.print(number);
                } catch (InterruptedException | BrokenBarrierException e) {
                    Thread.currentThread().interrupt();
                }
            }
        });

        letterThread.start();
        numberThread.start();

        try {
            letterThread.join();
            numberThread.join();
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
    }
}

代碼錯誤分析

當前代碼的邏輯是兩個線程交替打印字母和數(shù)字，但是由于CyclicBarrier的使用不當，導致輸出結(jié)果為ab12cd34。

具體原因是在字母線程中先打印字母再等待，而在數(shù)字線程中先等待再打印數(shù)字，這會導致字母線程先打印兩個字母后，數(shù)字線程才開始打印。

修改方案

為了實現(xiàn)交替打印的效果，可以調(diào)整線程的執(zhí)行順序。

具體來說，可以讓字母線程先等待，然后打印字母；而數(shù)字線程先等待，然后打印數(shù)字。這樣可以確保兩個線程交替執(zhí)行。

修改后的代碼

package com.zxl.a1b2c3d4;

import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;

public class AlternatePrintCyclicBarrier {

    private static final CyclicBarrier barrier = new CyclicBarrier(2);

    public static void main(String[] args) {
        String letters = "abcd";
        String numbers = "1234";

        Thread letterThread = new Thread(() -> {
            for (char letter : letters.toCharArray()) {
                try {
                    barrier.await(); // 等待數(shù)字線程
                    System.out.print(letter);
                    barrier.await(); // 等待數(shù)字線程
                } catch (InterruptedException | BrokenBarrierException e) {
                    Thread.currentThread().interrupt();
                }
            }
        });

        Thread numberThread = new Thread(() -> {
            for (char number : numbers.toCharArray()) {
                try {
                    barrier.await(); // 等待字母線程
                    System.out.print(number);
                    barrier.await(); // 等待字母線程
                } catch (InterruptedException | BrokenBarrierException e) {
                    Thread.currentThread().interrupt();
                }
            }
        });

        letterThread.start();
        numberThread.start();

        try {
            letterThread.join();
            numberThread.join();
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
    }
}