在 Spring Webserver 中创建线程以运行具有超时的任务答案

【问题标题】：Creating a thread to run tasks with a timeout in a Spring Webserver在 Spring Webserver 中创建线程以运行具有超时的任务
【发布时间】：2016-08-04 18:10:15
【问题描述】：

我正在尝试创建一个运行一组任务的线程，如果它没有在特定时间（比如 100 秒）内完成，则会引发异常。目前我正在尝试通过将任务封装到runnable 对象中并使用ExecutorService 和Future 类来执行超时执行来做到这一点。但是，当我启动我的 Web 服务时，我得到了这个异常：

java.util.concurrent.ExecutionException: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'scopedTarget.localhostInterpolatorHealthCheck': Scope 'request' is not active for the current thread; consider defining a scoped proxy for this bean if you intend to refer to it from a singleton; nested exception is java.lang.IllegalStateException: No thread-bound request found: Are you referring to request attributes outside of an actual web request, or processing a request outside of the originally receiving thread? If you are actually operating within a web request and still receive this message, your code is probably running outside of DispatcherServlet/DispatcherPortlet: In this case, use RequestContextListener or RequestContextFilter to expose the current request.
at java.util.concurrent.FutureTask.report(FutureTask.java:122)
at java.util.concurrent.FutureTask.get(FutureTask.java:202)

我在网上读到它并不像定义自己的线程并启动它们以在 Spring 上启动线程那么简单，所以我想知道如何做到这一点？我错过了什么？

【问题讨论】：

根据异常消息，您的任务正在使用具有请求范围的 spring bean，而您的计划线程执行不在请求范围内。附上任务代码或描述它在做什么
@AdamSkywalker 它正在创建一个扩展可运行的类，将该类封装在一个线程中，并使用Future 和ExecutorService 来执行限时代码块。代码块运行一系列健康测试。新类没有支持它的 bean（我认为它不是必需的），这可能是我出错的地方吗？
我没有足够的信息，我看到代码以某种方式使用了 spring bean。你有完整的堆栈跟踪吗？现在它只显示异常的顶部。
@AdamSkywalker 很长。我应该通过聊天或其他方式将其发送给您吗？
是的，你可以使用聊天

标签： java spring multithreading spring-mvc

【解决方案1】：

试试这个：

   /**
     * Executes a task with a specified timeout.
     */
    public final class TimeoutController {

        /**
         * Do not instantiate objects of this class. Methods are static.
         */
        private TimeoutController() {
        }

        /**
         * Executes <code>task</code>. Waits for <code>timeout</code>
         * milliseconds for the task to end and returns. If the task does not return
         * in time, the thread is interrupted and an Exception is thrown.
         * The caller should override the Thread.interrupt() method to something that
         * quickly makes the thread die or use Thread.isInterrupted().
         * @param task The thread to execute
         * @param timeout The timeout in milliseconds. 0 means to wait forever.
         * @throws TimeoutException if the timeout passes and the thread does not return.
         */
        public static void execute(Thread task, long timeout) throws TimeoutException {
            task.start();
            try {
                task.join(timeout);
            } catch (InterruptedException e) {
                /* if somebody interrupts us he knows what he is doing */
            }
            if (task.isAlive()) {
                task.interrupt();
                throw new TimeoutException();
            }
        }

        /**
         * Executes <code>task</code> in a new deamon Thread and waits for the timeout.
         * @param task The task to execute
         * @param timeout The timeout in milliseconds. 0 means to wait forever.
         * @throws TimeoutException if the timeout passes and the thread does not return.
         */
        public static void execute(Runnable task, long timeout) throws TimeoutException {
            Thread t = new Thread(task, "Timeout guard");
            t.setDaemon(true);
            execute(t, timeout);
        }

        /**
         * Signals that the task timed out.
         */
        public static class TimeoutException extends Exception {
            /** Create an instance */
            public TimeoutException() {
            }
        }
    }

【讨论】：

同样的错误：线程“Thread-25”中的异常 org.springframework.beans.factory.BeanCreationException：创建名称为“scopedTarget.localhostInterpolatorHealthCheck”的 bean 时出错：范围“请求”对当前无效线;如果您打算从单例中引用它，请考虑为该 bean 定义一个作用域代理；嵌套异常是 java.lang.IllegalStateException：原因：java.lang.IllegalStateException：未找到线程绑定请求：
你没有正确定义bean scopedTarget.localhostInterpolatorHealthCheck，线程无法从这个bean获取请求。
在你的spring配置中正确定义你的bean然后它就可以工作了。
“正确定义 bean”是什么意思？

【解决方案2】：

您可以使用多个 @async 方法，然后从您的主代码流中运行它们，获取期货列表。超时通过后，您可以获得结果或停止执行（取消/终止）。

这有好处，因为您将调用 spring 托管 bean，因此您可以使用所有依赖注入的属性。但是您应该注意提交的作业/线程的数量。

为了使用 @async 注释，您需要通过使用 xml 配置中的特定行或 bean 上的 AsyncEnabled 注释来启用异步内容。

【讨论】：