Java多线程交替执行：利用Semaphore实现精确同步

import java.util.concurrent.Semaphore;

public class SemTest {
    Semaphore sem1 = new Semaphore(1); // 控制线程1，初始允许执行
    Semaphore sem2 = new Semaphore(0); // 控制线程2，初始不允许执行

    public static void main(String args[]) {
        final SemTest semTest1 = new SemTest(); // 实例1
        final SemTest semTest2 = new SemTest(); // 实例2

        new Thread() {
            @Override
            public void run() {
                try {
                    semTest1.numb1(); // 线程1操作实例1的numb1方法
                } catch (Exception e) {
                    throw new RuntimeException(e);
                }
            }
        }.start();

        new Thread() {
            @Override
            public void run() {
                try {
                    semTest2.numb2(); // 线程2操作实例2的numb2方法
                } catch (Exception e) {
                    throw new RuntimeException(e);
                }
            }
        }.start();
    }

    private void numb1() {
        while (true) {
            try {
                sem1.acquire(); // 尝试获取sem1许可
                System.out.print(" 1");
                sem2.release(); // 释放sem2许可
                Thread.sleep(1000); // 模拟工作
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

    private void numb2() {
        while (true) {
            try {
                sem2.acquire(); // 尝试获取sem2许可
                System.out.print(" 2");
                sem1.release(); // 释放sem1许可
                Thread.sleep(1000); // 模拟工作
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

import java.util.concurrent.Semaphore;

public class CorrectSemTest {

    public static void main(String args[]) {
        // 关键：sem1和sem2被定义在main方法中，并由匿名线程类“捕获”
        // 确保了两个线程操作的是同一对Semaphore实例
        final Semaphore sem1 = new Semaphore(1); // 初始允许线程1执行
        final Semaphore sem2 = new Semaphore(0); // 初始阻止线程2执行

        // 线程1：负责打印“1”
        new Thread(new Runnable() {
            @Override
            public void run() {
                try {
                    while (true) {
                        sem1.acquire(); // 获取sem1许可，如果为0则阻塞
                        System.out.print(" 1");
                        sem2.release(); // 释放sem2许可，允许线程2执行
                        Thread.sleep(500); // 模拟工作耗时
                    }
                } catch (InterruptedException e) {
                    Thread.currentThread().interrupt(); // 恢复中断状态
                    System.err.println("Thread 1 interrupted.");
                }
            }
        }).start();

        // 线程2：负责打印“2”
        new Thread(new Runnable() {
            @Override
            public void run() {
                try {
                    while (true) {
                        sem2.acquire(); // 获取sem2许可，如果为0则阻塞
                        System.out.print(" 2");
                        sem1.release(); // 释放sem1许可，允许线程1执行
                        Thread.sleep(500); // 模拟工作耗时
                    }
                } catch (InterruptedException e) {
                    Thread.currentThread().interrupt(); // 恢复中断状态
                    System.err.println("Thread 2 interrupted.");
                }
            }
        }).start();
    }
}