交替打印 FooBar

/* 思路：
 * 使用 Java Stream 来实现该功能虽然不常见，但可以通过并行流和同步机制结合来实现。
 * 我们依然使用锁和条件变量来确保线程同步，并结合 Java Stream 的并行处理能力。
 */

import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
import java.util.stream.IntStream;

public class FooBarStream {
    private int n;
    private Lock lock = new ReentrantLock();
    private Condition fooCondition = lock.newCondition();
    private Condition barCondition = lock.newCondition();
    private boolean fooTurn = true;

    public FooBarStream(int n) {
        this.n = n;
    }

    public void foo() throws InterruptedException {
        IntStream.range(0, n).parallel().forEach(i -> {
            lock.lock();
            try {
                while (!fooTurn) {
                    fooCondition.await();
                }
                System.out.print("foo");
                fooTurn = false;
                barCondition.signal();
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            } finally {
                lock.unlock();
            }
        });
    }

    public void bar() throws InterruptedException {
        IntStream.range(0, n).parallel().forEach(i -> {
            lock.lock();
            try {
                while (fooTurn) {
                    barCondition.await();
                }
                System.out.print("bar");
                fooTurn = true;
                fooCondition.signal();
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            } finally {
                lock.unlock();
            }
        });
    }
}