具有会话的异步服务

Question

我有一个方法要调用一个存储函数。我希望它异步地完成它的工作。这就是我所拥有的，但似乎.doWork（）从未启动，因为当我调用＜code＞getDao时。deleteAll（），存储的函数不运行。

@Transactional
    public void delete()
    {

        final Session session = (Session) entityManager.getDelegate();
        ExecutorService executorService = Executors.newSingleThreadExecutor();
        executorService.execute(new Runnable()
        {
            @Override
            public void run()
            {
                LOGGER.warn("starting");
                session.doWork(new Work()
                {
                    @Override
                    public void execute(Connection connection) throws SQLException
                    {
                        try
                        {

                            CallableStatement purgeArchived = connection.prepareCall("{call deleteAll()}");
                            purgeArchived.execute();
                        }
                        catch (SQLException exception)
                        {
                            LOGGER.warn("Failed to purge archive points. Reason: " + exception);
                        }
                    }
                });
                LOGGER.warn("stopping");
            }
        });
        executorService.shutdown();
    }

我看到记录器已经记录了“启动”，但它从未到达“停止”为什么会发生这种情况？

Answer 1

请注意，当您有一个单独的线程时，@Transaction是没有实际意义的，因为Transaction通常是线程绑定的。

您将需要在run（）中从工厂获取一个新的entityManager。

也可以选择@Async，它要干净得多。

再次注意@Async的事务性

@Async和@Transactional:不起作用

作为一个通用的经验法则，如果你想做一些异步工作——把它当作一个单独的工作单元和一个单独的事务。