Как создать независимый поток с помощью Spring @Async

Я использую Spring @Async с weblogic workmanager, версия Spring 3.2.2.

Web.xml:

<resource-ref>
    <res-ref-name>ReportWorkmanager</res-ref-name>
    <res-type>commonj.work.WorkManager</res-type>
    <res-auth>Container</res-auth>
    <res-sharing-scope>Shareable</res-sharing-scope>
</resource-ref>

weblogic.xml:

<work-manager>
    <name>ReportWorkmanager</name>
    <fair-share-request-class>
        <name>Priority</name>
        <fair-share>100</fair-share>
    </fair-share-request-class>

    <min-threads-constraint>
        <name>MinThreadCount</name>
        <count>15</count>
    </min-threads-constraint>

    <max-threads-constraint>
        <name>MaxThreadCount</name>
        <count>25</count>
    </max-threads-constraint>

    <work-manager-shutdown-trigger>
        <max-stuck-thread-time>120</max-stuck-thread-time>
        <stuck-thread-count>25</stuck-thread-count>
    </work-manager-shutdown-trigger>
</work-manager>

XML-файл конфигурации Spring:

 <bean id="reportWorkManagerTaskExecutor"
    class="org.springframework.scheduling.commonj.WorkManagerTaskExecutor">
    <property name="workManagerName" value="java:comp/env/ReportWorkmanager" />
</bean>

Контроллер:

@RequestMapping(value = "/publish", method = RequestMethod.POST)
public MarketingScenario publishReport(@RequestBody final PublishReportDTO reportDTO, final HttpServletRequest request) throws Exception {


    reportDTO.setReqUserName(DominoWebUtil.getLoggedInUserName(request));
    reportEngine.publishReport(reportDTO);
    MarketingScenario scenario =  scenarioService.findMarketingScenarioById(reportDTO.getScenarioId());
    _LOGGER.debug("Job submitted , successfully came out for scenario id {}", reportDTO.getScenarioId());
    return scenario;
}

Услуга :

@Async(value = "reportWorkManagerTaskExecutor")
public void publishReport(final PublishReportDTO reportDTO) {

    //Some long run job
}

Всякий раз, когда запрос поступает из fornt end , контроллер должен инициировать задание, вызывая метод службы, и он должен возвращать ответ без ожидания задания службы.

Когда @Async не применяется, все идет отлично, но когда я применил, служебный поток уничтожается, потому что мой поток запросов выполнен.

Пожалуйста, дайте мне знать, используя @Async, как создать поток, независимый от потока запросов.

Этот независимый поток может работать в течение 2 или 20 минут в зависимости от ввода.


java multithreading spring-mvc asynchronous workmanagers
person Phani Kumar Bhavirisetty    schedule 13.11.2014    source источник

Ответы (1)


arrow_upward
1
arrow_downward

Во-первых, Spring docs утверждают, что @Async с исполнителем, отличным от исполнителя по умолчанию, следует аннотировать с помощью @Async("otherExecutor"), а не @Async(value="otherExecutor").

Кроме того, я не думаю, что совсем понимаю, что вы имеете в виду под этим:

Когда @Async не применяется, все идет отлично, но когда я применил, служебный поток уничтожается, потому что мой поток запросов выполнен.

Я предполагаю, что вы имеете в виду, что он работает нормально, но в том же потоке. В этом случае это имеет смысл, поскольку вы запускаете этот метод синхронно.

person maaw    schedule 27.01.2016