12

我有一个定期运行的主线程。它使用 setAutoCommit(false) 打开一个连接，并作为引用传递给少数子线程以执行各种数据库读/写操作。在子线程中执行了相当数量的操作。在所有子线程完成它们的数据库操作后，主线程使用打开的连接提交事务。请注意，我在 ExecutorService 中运行线程。我的问题，是否建议跨线程共享连接？如果“是”，请查看以下代码是否正确实现它。如果“否”，在多线程场景中执行事务的其他方法是什么？欢迎评论/建议/新想法。伪代码...

Connection con = getPrimaryDatabaseConnection();
// let me decide whether to commit or rollback
con.setAutoCommit(false);

ExecutorService executorService = getExecutor();
// connection is sent as param to the class constructor/set-method
// the jobs uses the provided connection to do the db operation
Callable jobs[] = getJobs(con); 
List futures = new ArrayList();
// note: generics are not mentioned just to keep this simple
for(Callable job:jobs) {
    futures.add(executorService.submit(job));
}
executorService.shutdown();
// wait till the jobs complete
while (!executorService.isTerminated()) {
  ;
}

List result = ...;
for (Future future : futures) {
    try {
       results.add(future.get());
    } catch (InterruptedException e) {
      try {
        // a jobs has failed, we will rollback the transaction and throw exception
        connection.rollback();
        result  = null;
        throw SomeException();
      } catch(Exception e) {
       // exception
      } finally {
         try {
           connection.close();
         } catch(Exception e) {//nothing to do}
      }    
   }
}
// all the jobs completed successfully!
try {
  // some other checks
  connection.commit();
  return results;
} finally {
  try {
      connection.close();
  } catch(Exception e){//nothing to do}
}
4

3 回答 3

3

我不建议您在线程之间共享连接，因为连接操作非常慢并且您的应用程序的整体性能可能会受到损害。

我宁愿建议您使用Apache Connections Pool并为每个线程提供单独的连接。

于 2013-09-19T14:31:22.123 回答
1

您可以创建一个代理类来保存 JDBC 连接并提供对它的同步访问。线程不应该直接访问连接。

根据您提供的用途和操作，您可以使用synchronized方法，或者如果代理需要锁定直到他离开某个状态，则锁定对象。

对于那些不熟悉代理设计模式的人。这里是维基文章。基本思想是代理实例隐藏另一个对象，但提供相同的功能。

于 2013-09-19T14:18:47.867 回答
1

在这种情况下，请考虑为每个工作人员创建一个单独的连接。如果任何一个工作人员失败，则回滚所有连接。如果全部通过，则提交所有连接。

如果您将拥有数百名工作人员，那么您需要提供对 Connection 对象的同步访问，或者使用@mike 和@NKukhar 建议的连接池。

于 2013-09-19T18:01:27.883 回答