将服务层传递给线程的正确方法

Question

我的服务层方法是事务性的，当我使用 ExecutorService 并将任务提交给线程时，我无法将 servicelayer 作为参数传递给每个线程，因为我得到了错误

Dec 14, 2009 10:40:18 AM com.companyx.applicationtest.applicationtestcompanyx.services.threadtestRunnable run
SEVERE: null
org.hibernate.HibernateException: No Hibernate Session bound to thread, and conf
iguration does not allow creation of non-transactional one here
        at org.springframework.orm.hibernate3.SpringSessionContext.currentSessio
n(SpringSessionContext.java:63)
        at org.hibernate.impl.SessionFactoryImpl.getCurrentSession(SessionFactor
yImpl.java:542)

我的服务层

ExecutorService executor = Executors.newFixedThreadPool(10);
                  for (final Object item : CollectionsTest{ 
                      executor.submit(new threadtestRunnable((Long)item,collectionAfterfiltered,this));  //'this' is service layer
                  }

1. 我应该像这样将服务层传递给每个线程吗？
2. 什么是正确的方法，我需要每个线程调用服务层中的方法？ （我用的是弹簧）

Answer 1

通常，如 cmets 所述，事务不应在多个线程中运行。但是，在某些情况下，它是可以接受的。

• 您需要与 Web 服务进行一些异步通信（不让用户等待结果），并在结果到来时存储结果
• 您需要多个线程中的只读事务。

如果您使用new 创建线程，则它不是弹簧上下文的一部分。因此，当创建线程的方法完成时，您的事务拦截器将关闭事务（以及最终的会话），您将得到上述异常。

（更多详情-Spring docs，见“查找注​​入”）

您需要在 spring 上下文中创建线程。由于您可能是从 singleton bean 创建它们，因此从 singleton bean 创建 prototype bean 的情况很少见。所以为了在spring上下文中创建线程，可以使用：

 <bean id="mainBean"
    class="com.my.MyClass">
    <lookup-method name="createThread" bean="myThreadBean"/>
 </bean>

您还应该将ThreadtestRunnable 类映射到applicationContext.xml 或将其注释为@Component("myThreadBean")。

然后在名为createThread 的主bean 上定义一个abstract 方法并返回您的线程类。用@Transactional 注释你的run 方法（或定义适当的aop 规则），然后尝试一下。也许您需要在您的@Transactional 中设置propagation=Propagation.REQUIRES_NEW"。如果有任何问题，请回到这里。