java - session 在 ExecutorService 内部时关闭

Question

当我尝试在 myExecutor.execute(new Runnable() ...) 中调用 session.createSQLQuery() 时，出现异常:

SessionException: Session is closed!

为什么 session 在ExecutorService.execute期间关闭？

我必须在execute中创建一个新的entityManager吗？

ExecutorService executor = newSingleThreadExecutor();
executor.execute(new Runnable()
    {
        @Override
        public void run()
        {
            Session session = (Session) entityManager.getDelegate();
            SQLQuery query = session.createSQLQuery("SELECT * FROM function()");
        }
    }

Answer 1

通常，每个线程都有自己的 session 。 ExecutorService 有自己的线程，因此您需要在 run() 方法中管理执行程序线程内的实体管理器、 session 和事务。