java中，如果有一个方法是做某事的，现在我想增加多线程去执行这段代码，在不改变这段代码的基础上，如何实现，当所有的线程执行完后，如果没有一个线程出错，那么就统一提交事务，如果有一个出错，就回滚事务

在Java中，为了实现这样的需求，你可以使用`ExecutorService`和`Callable`或`Runnable`结合`Future`和`Transaction`管理。这里是一个简化的示例：

首先，创建一个实现了`Callable`或`Runnable`接口的任务，例如，假设你有一个名为`Task`的类：

public class Task implements Callable<Void> {
    private boolean success; // 标记任务是否成功

    public Task() {
        // 初始化任务...
    }

    @Override
    public Void call() throws Exception {
        try {
            // 执行任务代码
            if (/*任务执行完成且无异常*/) {
                success = true;
            }
        } catch (Exception e) {
            success = false; // 如果发生错误，将success设置为false
            throw e; // 遵循"fail fast"原则，立即抛出异常
        }
        return null;
    }
}

然后，你可以使用`ExecutorService`并发地执行这些任务，并处理结果：

ExecutorService executor = Executors.newFixedThreadPool(5); // 创建固定大小的线程池
List<Future<Void>> futures = new ArrayList<>();

// 将任务加入到工作队列
for (int i = 0; i < numTasks; i++) {
    Future<Void> future = executor.submit(new Task());
    futures.add(future);
}

try {
    // 等待所有任务完成
    for (Future<Void> future : futures) {
        future.get(); // 获取未来的结果，如果有错误会中断并回滚
    }

    // 所有任务都成功，提交事务
    TransactionManager.commit();

} catch (InterruptedException | ExecutionException e) {
    // 有任务失败或中断，捕获异常并回滚事务
    TransactionManager.rollback();
    throw e; // 抛出自定义的错误，以便进一步处理
} finally {
    executor.shutdown(); // 关闭线程池
}

在这个例子中，`TransactionManager`是自定义的用于事务控制的对象，它负责事务的开始、提交或回滚。