Политика справедливости синхронной очереди в bean-компоненте ThreadPoolTaskExecutor?

У меня есть следующий боб

<bean id="executor"
    class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
    <property name="corePoolSize" value="1" />
    <property name="maxPoolSize" value="1" />
    <!-- Positive value leads to LinkedBlockingQueue,
        any other value leads to SynchronousQueue -->
    <property name="queueCapacity" value="0" />
</bean>

Документация Oracle для SynchronousQueue говорит следующее:

Этот класс поддерживает необязательную политику справедливости для упорядочивания ожидающих потоков производителя и потребителя. По умолчанию такой порядок не гарантируется. Однако очередь, созданная с равноправием, равным true, предоставляет потокам доступ в порядке FIFO.

Мой вопрос: как я могу указать, что мне нужна справедливость заказа в моей конфигурации bean-компонента?

Спасибо!


java multithreading spring threadpoolexecutor threadpool
person zkristic    schedule 24.03.2015    source источник

Ответы (1)


arrow_upward
2
arrow_downward

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

Но все же, если вы хотите, вы можете расширить ThreadPoolTaskExecutor и просто переопределить createQueue() следующим образом:

public class FairThreadPoolTaskExecutor extends ThreadPoolTaskExecutor {
    protected BlockingQueue<Runnable> createQueue(int queueCapacity) {
        return (BlockingQueue) (queueCapacity > 0 ? new LinkedBlockingQueue(queueCapacity) : new SynchronousQueue(true));
    }
}
person hemant1900    schedule 24.03.2015
comment
Спасибо, это один из способов сделать это ... Я думал, что может быть свойство для исполнителя задач пула потоков, но похоже, что его нет. Ваше здоровье - person zkristic; 25.03.2015