Доступ к областям профилированных объектов в streamах

У меня есть веб-приложение, работающее в tomcat, где я использую ThreadPool (Java 5 ExecutorService), чтобы параллельно выполнять интенсивные операции ввода-вывода для повышения производительности. Я хотел бы, чтобы некоторые из компонентов, используемых в каждом объединенном streamе, были в области запроса, но streamи в ThreadPool не имеют доступа к контексту весны и получают прокси-отказ. Любые идеи о том, как сделать весенний контекст доступными для streamов ThreadPool для устранения сбоев прокси?

Я предполагаю, что должен быть способ зарегистрировать / отменить регистрацию каждого streamа в ThreadPool с весной для каждой задачи, но не успел найти, как это сделать.

Благодаря!

Я использую следующий суперclass для своих задач, которые должны иметь доступ к области запроса. В основном вы можете просто расширить его и реализовать свою логику в методе onRun ().

import org.springframework.web.context.request.RequestAttributes; import org.springframework.web.context.request.RequestContextHolder; /** * @author Eugene Kuleshov */ public abstract class RequestAwareRunnable implements Runnable { private final RequestAttributes requestAttributes; private Thread thread; public RequestAwareRunnable() { this.requestAttributes = RequestContextHolder.getRequestAttributes(); this.thread = Thread.currentThread(); } public void run() { try { RequestContextHolder.setRequestAttributes(requestAttributes); onRun(); } finally { if (Thread.currentThread() != thread) { RequestContextHolder.resetRequestAttributes(); } thread = null; } } protected abstract void onRun(); }

Я также хотел бы, чтобы у меня было 1000 голосов, чтобы дать принятый в настоящее время ответ. Я был в тупике, как это сделать в течение некоторого времени. На основе этого, вот мое решение, используя интерфейс Callable, если вы хотите использовать некоторые из новых вещей @Async в Spring 3.0.

 public abstract class RequestContextAwareCallable implements Callable { private final RequestAttributes requestAttributes; private Thread thread; public RequestContextAwareCallable() { this.requestAttributes = RequestContextHolder.getRequestAttributes(); this.thread = Thread.currentThread(); } public V call() throws Exception { try { RequestContextHolder.setRequestAttributes(requestAttributes); return onCall(); } finally { if (Thread.currentThread() != thread) { RequestContextHolder.resetRequestAttributes(); } thread = null; } } public abstract V onCall() throws Exception; }

Не могли бы вы попробовать это наоборот? Используйте контейнер данных, который хранится в области запроса, и передайте его в пул streamов (возможно, поместите его в очередь, чтобы пул streamов мог принимать один контейнер данных за раз, работать над ним, отмечать его как «сделанный» и продолжать со следующим).

Spring имеет class ThreadPoolTaskExecutor, который вы можете использовать для управления пулом streamов из Spring. Тем не менее, похоже, что вам нужно будет сделать некоторую работу, чтобы сделать контекст Spring доступным для каждого streamа.

Я не уверен, что это сработает, даже если вы все-таки подключитесь к этому. Spring использует токен в локальном streamе для поиска объектов в области запроса (или сеанса), поэтому, если вы пытаетесь получить доступ к компоненту области запроса из другого streamа, вполне вероятно, что токена там не будет.

Пул streamов с использованием boost asio

Пул streamов C ++

Когда использовать пул streamов в C #?

Тема против ThreadPool

Именование streamов и streamов-streamов ExecutorService

Как реализовать PriorityBlockingQueue с помощью ThreadPoolExecutor и настраиваемых задач

Параметры TaskCreationOptions.LongRunning и ThreadPool

ExecutorService, как ждать завершения всех задач

Сколько streamов слишком много?

Как создать пул streamов, используя boost в C ++?

Что такое эквивалент async / await сервера ThreadPool?