给个CyclicBarrier控制多线程事务回滚的示例

好的，下面是一个使用 CyclicBarrier 控制多线程事务回滚的示例代码：

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

public class TransactionRollbackDemo {
    private static final int THREAD_COUNT = 3;

    private static CyclicBarrier cyclicBarrier = new CyclicBarrier(THREAD_COUNT, new Runnable() {
        @Override
        public void run() {
            System.out.println("All threads have arrived, starting to rollback...");
            // TODO: 执行回滚操作
        }
    });

    public static void main(String[] args) {
        for (int i = 0; i < THREAD_COUNT; i++) {
            new Thread(new Worker(i)).start();
        }
    }

    static class Worker implements Runnable {
        private int workerId;

        public Worker(int workerId) {
            this.workerId = workerId;
        }

        @Override
        public void run() {
            try {
                System.out.println("Worker " + workerId + " is working...");
                Thread.sleep(1000);
                System.out.println("Worker " + workerId + " has finished working, waiting for others...");
                cyclicBarrier.await();
            } catch (InterruptedException e) {
                e.printStackTrace();
            } catch (BrokenBarrierException e) {
                e.printStackTrace();
            }
        }
    }
}

上面的代码中，我们创建了一个 CyclicBarrier 对象，设置了等待的线程数量为 3，并且在所有线程都到达屏障点时执行一个回调函数来执行回滚操作。

然后我们创建了 3 个 Worker 线程，并且在每个线程中执行一些任务，然后通过调用 cyclicBarrier.await() 方法来等待其他线程到达屏障点。

当所有线程都到达屏障点时，CyclicBarrier 会执行回调函数来执行回滚操作。

注意，上面的示例代码中，回滚操作只是一个 TODO 注释，需要根据具体的业务场景来实现具体的回滚逻辑。