ExecutorService, который запускает задачи в вызывающем потоке?

Существуют ли какие-либо реализации java.util.ExecutorService, которые просто запускают все выполняемые задачи в вызывающем потоке? Если это не включено в Java по умолчанию, существует ли библиотека, содержащая подобную реализацию?


java threadpool executorservice
person Naftuli Kay    schedule 13.08.2012    source источник
comment
См. документацию по Executor; увидеть их DirectExecutor? Приложив немного усилий, вы можете превратить его в ExecutorService.   -  person obataku    schedule 14.08.2012

Ответы (3)


arrow_upward
2
arrow_downward

Единственная существующая реализация, которую я смог найти, это SynchronousExecutorService — к сожалению, похоронен где-то в camel.

Вставка исходного кода (без комментариев) здесь для дальнейшего использования:

package org.apache.camel.util.concurrent;

import java.util.List;
import java.util.concurrent.AbstractExecutorService;
import java.util.concurrent.TimeUnit;

public class SynchronousExecutorService extends AbstractExecutorService {

    private volatile boolean shutdown;

    public void shutdown() {
        shutdown = true;
    }

    public List<Runnable> shutdownNow() {
        return null;
    }

    public boolean isShutdown() {
        return shutdown;
    }

    public boolean isTerminated() {
        return shutdown;
    }

    public boolean awaitTermination(long time, TimeUnit unit) throws InterruptedException {
        return true;
    }

    public void execute(Runnable runnable) {
        runnable.run();
    }

}
person Tomasz Nurkiewicz    schedule 13.08.2012
comment
Вероятно, следует убедиться, что он не отключен в execute. - person obataku; 14.08.2012
comment
@veer: правда, но это не мой код. Не стесняйтесь обращаться к разработчикам Camel. - person Tomasz Nurkiewicz; 14.08.2012
comment
Верно, верно, но я имел в виду, что это скорее предложение к ОП, а не к вам ... :p - person obataku; 14.08.2012

arrow_upward
5
arrow_downward

Вы можете использовать Guava com.google.common.util.concurrent.MoreExecutors.sameThreadExecutor(), который делает именно то, что вы хотите: https://github.com/google/guava/blob/0434c5199c83c3f43b8b6a86c62e121d518fe7d0/guava/src/com/google/common/util/concurrent/MoreExecutors.java#L267

РЕДАКТИРОВАТЬ: метод был переименован в com.google.common.util.concurrent.MoreExecutors.newDirectExecutorService() https://github.com/google/guava/blob/f67ab864bde63fa6602b5688de0440957ffeaa2e/guava/src/com/google/common/util/concurrent/MoreExecutors.java#L369

person Pierre-Luc Bertrand    schedule 31.01.2013

arrow_upward
0
arrow_downward

вы смотрели на java.util.concurrent.ThreadPoolExecutor?

person Ayusman    schedule 13.08.2012
comment
Да. Я попытался запустить его с 0 потоками и политикой отклонения потоков Caller Runs, но это не удается с исключением. - person Naftuli Kay; 14.08.2012