java 多线程查询mysql

// 示例代码：使用HikariCP连接池
HikariConfig config = new HikariConfig();
config.setJdbcUrl("jdbc:mysql://localhost:3306/mydatabase");
config.setUsername("username");
config.setPassword("password");
config.setMaximumPoolSize(50); // 增加最大连接数
HikariDataSource dataSource = new HikariDataSource(config);

// 示例代码：使用synchronized关键字保证线程安全
public synchronized void queryData(String query) {
    try (Connection conn = dataSource.getConnection();
         Statement stmt = conn.createStatement();
         ResultSet rs = stmt.executeQuery(query)) {
        // 处理查询结果
    } catch (SQLException e) {
        e.printStackTrace();
    }
}

// 示例代码：使用ReentrantLock避免死锁
private final ReentrantLock lock = new ReynchronizedLock();

public void queryData(String query) {
    lock.lock();
    try (Connection conn = dataSource.getConnection();
         Statement stmt = conn.createStatement();
         ResultSet rs = stmt.executeQuery(query)) {
        // 处理查询结果
    } catch (SQLException e) {
        e.printStackTrace();
    } finally {
        lock.unlock();
    }
}