Проблема при выполнении асинхронных задач с использованием ExecutorService

Ранее я задавал вопрос относительно инициализации ExecutorService и Apache Velocity. Для краткого обзора - у меня есть интерфейс Java EE, который принимает пользовательские запросы, а затем для каждого из этих запросов использует ExecutorService (SingleThreadedExecutor, установленный в качестве демона) для запуска длинного рабочего процесса. Этот рабочий процесс содержится в библиотеке и работает ну и как положено при запуске в автономном режиме через затмение. При вызове с веб-сайта (сервлета) я заметил, что рабочие процессы постоянно зависали в момент инициализации Velocity Engine (Velocity.init() или ve.init()). Отсюда мой вышеупомянутый вопрос.

Когда ни одно из ответов / предложений не сработало, я понял, что это как-то связано с тем, как Velocity запустился, и решил перейти на FreeMarker. Теперь я вижу, что рабочий процесс зависает в том же месте, что и реализация FreeMarker. Это "место" является частью построения почты, которая оценивает шаблон по совокупности переданных объектов данных и возвращает почтовую строку. Класс, который вызывает класс Freemark'ing и класс FreeMark, выглядит следующим образом:

   public class mailBuilder {

    private static final Logger log = Logger.getLogger( mailBuilder.class );    
    static String a;
    static String b;

    public mailBuilder(CustomDataStructure input)
    {
        a = input.getA();
        b = input.getB(); 
    }
    public static String returnMailstring() throws Exception
    {
        log.info("Gathering elements to construct email.");
        String mailText=null;
        Map context = new HashMap();
        context.put("a",a);
        context.put("b",b);
        log.info("Calling Freemarker");
        mailText=FreeMarkIT.ReturnReportString(context);
        log.info("Freeemarker returned string");

        return mailText;
    }
}

Класс FreeMarkIT выглядит следующим образом -

    public class FreeMarkIT {
        private static final Logger log = Logger.getLogger( FreeMarkIT.class );
        private static Configuration config;
        private static Template template;

        public static String ReturnReportString(Map model) throws IOException, TemplateException
        {
            StringWriter sw = new StringWriter();
            try 
            {
               log.info("Going to get the template");
               config= new Configuration();
               log.info("Now really");
               template=config.getTemplate("src/resource/email_template.vm");
               log.info("Done initializing template");
               template.process(model, sw);
               sw.flush();
            }
            catch(Exception e)
            {
                System.out.println(e.getMessage());
            }

            return sw.getBuffer().toString();
        }
    }

Теперь из моей регистрации это выглядит как рабочий поток висит на линии config=new Configuration()

Опять же, это работает должным образом в автономном режиме при запуске из eclipse, но, однако, зависает при вызове из сервлета с использованием ExecutorService.

Я начинаю думать / понимать, что это может не иметь ничего общего ни с Velocity, ни с FreeMarker, а иметь какое-то отношение к ExecutorService. Любой совет или предложение будут иметь огромную помощь.

Спасибо

1 ответ

Решение

Ваш код не является потокобезопасным, так как вы делитесь config а также template через все экземпляры потоков (и постоянно их переустанавливать). самый простой способ сделать это потокобезопасным было бы сделать config а также template локальные переменные в методе вместо статических членов. как отметил @JBNizet в комментариях, у вас есть похожая проблема в mailBuilder с a а также b, Возможно, вы захотите сначала ознакомиться с некоторыми учебными пособиями по основам объектно-ориентированного программирования, а затем вернуться к этой проблеме (подсказка, как правило, вам следует избегать статических переменных-членов, за исключением констант).

Другие вопросы по тегам