同一事务中的多个线程

下面是一个使用Java语言的示例代码，演示了如何在同一事务中使用多个线程。

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;

public class MultiThreadTransactionExample {
    // 数据库连接配置
    private static final String DB_URL = "jdbc:mysql://localhost:3306/mydatabase";
    private static final String DB_USER = "username";
    private static final String DB_PASSWORD = "password";

    public static void main(String[] args) {
        // 创建两个线程，分别执行不同的任务
        Thread thread1 = new Thread(new Task1());
        Thread thread2 = new Thread(new Task2());

        // 启动线程
        thread1.start();
        thread2.start();

        try {
            // 等待两个线程执行完成
            thread1.join();
            thread2.join();

            // 提交事务
            commitTransaction();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

    private static void commitTransaction() {
        Connection connection = null;
        try {
            // 获取数据库连接
            connection = DriverManager.getConnection(DB_URL, DB_USER, DB_PASSWORD);

            // 手动开启事务
            connection.setAutoCommit(false);

            // 执行一些事务操作
            // ...

            // 提交事务
            connection.commit();

        } catch (SQLException e) {
            e.printStackTrace();
            try {
                // 出现异常时回滚事务
                if (connection != null) {
                    connection.rollback();
                }
            } catch (SQLException ex) {
                ex.printStackTrace();
            }
        } finally {
            try {
                if (connection != null) {
                    connection.close();
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

    // 第一个任务
    static class Task1 implements Runnable {
        @Override
        public void run() {
            Connection connection = null;
            try {
                // 获取数据库连接
                connection = DriverManager.getConnection(DB_URL, DB_USER, DB_PASSWORD);

                // 手动开启事务
                connection.setAutoCommit(false);

                // 执行一些事务操作
                // ...

                // 提交事务
                connection.commit();

            } catch (SQLException e) {
                e.printStackTrace();
                try {
                    // 出现异常时回滚事务
                    if (connection != null) {
                        connection.rollback();
                    }
                } catch (SQLException ex) {
                    ex.printStackTrace();
                }
            } finally {
                try {
                    if (connection != null) {
                        connection.close();
                    }
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    }

    // 第二个任务
    static class Task2 implements Runnable {
        @Override
        public void run() {
            Connection connection = null;
            try {
                // 获取数据库连接
                connection = DriverManager.getConnection(DB_URL, DB_USER, DB_PASSWORD);

                // 手动开启事务
                connection.setAutoCommit(false);

                // 执行一些事务操作
                // ...

                // 提交事务
                connection.commit();

            } catch (SQLException e) {
                e.printStackTrace();
                try {
                    // 出现异常时回滚事务
                    if (connection != null) {
                        connection.rollback();
                    }
                } catch (SQLException ex) {
                    ex.printStackTrace();
                }
            } finally {
                try {
                    if (connection != null) {
                        connection.close();
                    }
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

在上面的示例中，我们创建了两个线程Task1和Task2，它们分别执行不同的任务。在每个任务中，我们都创建了一个独立的数据库连接，并手动开启了事务。然后，我们可以在事务中执行一些数据库操作，例如插入、更新或删除数据。最后，我们提交事务，或者在出现异常时回滚事务。

请注意，这只是一个示例代码，具体的实现方式可能因不同的需求而有所不同。在实际开发中，您需要根据您的具体情况进行适当的修改和调整。