Описание тега executor
Use for questions related to nodes that are used to actually execute a distributed job/program/application.
5
ответов
Вызов метода для блоков Future.get(). Это действительно желательно?
Пожалуйста, внимательно прочитайте вопрос, прежде чем пометить его как дубликат. Ниже приведен фрагмент псевдокода. Мой вопрос: не нарушает ли приведенный ниже код само понятие параллельной асинхронной обработки? Причина, по которой я спрашиваю об э…
27 июн '15 в 18:27
1
ответ
Делает awaitTermination() делает сон программы
class SomeClass { void go() { //do stuff shutdownAndAwaitTermination(pool); System.exit(0); } public void shutdownAndAwaitTermination(ExecutorService pool) { pool.shutdown(); try { logger.log(Level.INFO, "Waiting for existing tasks to terminate"); i…
04 фев '14 в 10:48
2
ответа
Проблема с сервисом исполнителя в приложении Eclipse для Android
В основном, я разрабатываю живые обои OpenGL для телефонов Android. Это мой класс обслуживания обоев. public class Wallpaper extends GLWallpaperService { private class MyEngine extends Engine { private GLRenderer glRenderer; private GL10 gl; private…
13 сен '11 в 18:11
0
ответов
Ошибка исполнителя: хост был прерван
У моего приложения потокового воспроизведения (запущенного в HD Insights) постоянно возникают проблемы из-за сообщения об ошибке ниже: ExecutorLostFailure (executor 525 exited unrelated to the running tasks) Reason: Container container_1495825717937…
05 июн '17 в 21:39
2
ответа
Вызов Looper более одного раза вызывает "отправку сообщения обработчику в мертвой ветке"
Я использую Executor [исправленный пул потоков] с моей собственной ThreadFactory, которая добавляет Looper: Handler HANDLER = new Handler(); Executor THREADS = Executors.newFixedThreadPool(THREAD_POOL_SIZE, new ThreadFactory() { @Override public Thr…
04 сен '10 в 16:08
0
ответов
Метод ThreadExecutor
Я хочу создать метод в Java 8, который позволит мне выполнить запрос MongoDB в другом потоке. Для этого я хочу использовать (?) ExecutorService pool = Executors.newCachedThreadPool(); Теперь я обычно использую что-то вроде pool.execute (() -> Я хочу…
01 май '16 в 10:03
3
ответа
Android Callable
Как реализовать Callable, чтобы вернуть логическое значение и сделать что-то? Мне нужно использовать внешний поток для подключения к FTP-серверу, я не могу сделать это в основной деятельности, и мне нужно возвращаемое значение, чтобы знать, подключе…
08 янв '14 в 17:08
2
ответа
Мгновенно ли Future возвращает false для isDone() сразу после того, как исполнитель submit()
Не удалось найти документацию о будущем состоянии executor.submit() вызов. Пример: byte[] b = new byte[ 4000000 ]; new Random().nextBytes( b ); Callable<byte[]> c = new SorterCallable( b ); ExecutorService executor = Executors.newCachedThreadP…
24 июн '14 в 11:36
1
ответ
Как сохранить текстовое значение, возвращаемое из JavaScript, в строковую переменную в Java
Я пытаюсь сохранить текст, возвращаемый этим кодом JavaScript, в переменную Java String, но не могу этого достичь. Может кто-нибудь, пожалуйста, помогите с этим? Мой код: String script = "document.querySelector(\"\"#shift_m_driver>option:nth-chil…
18 мар '16 в 15:17
0
ответов
Grails: использование Javax.ws.rs.Client внутри runAsync
Я делаю запрос на получение из моей службы Grails в стороннюю службу, как показано в коде ниже. Код работает, как и ожидалось, но иногда Grails не может сделать запрос к сторонней службе, я использую это для отправки OTP в мое мобильное приложение. …
31 окт '17 в 05:46
4
ответа
Почему я получил сообщение о том, что ни одно исключение не выброшено?
У меня есть это в классе, который реализует Callable: public class MasterCrawler implements Callable { public Object call() throws SQLException { resumeCrawling(); return true; } //more code with methods that throws an SQLException } В другом классе…
27 май '11 в 01:59
2
ответа
Пауза ScheduledExecutorService
Я использую ScheduledExecutorService выполнить задачу, которая вызывает услугу по фиксированной ставке. Служба может вернуть некоторые данные в задачу. Задача хранит данные в очереди. Некоторые другие потоки медленно выбирают элементы из очереди imp…
01 июл '11 в 08:00
1
ответ
Как создать несколько пулов потоков, т. Е. Несколько исполнителей, каждый с одним потоком
В настоящее время мне нужно создать несколько потоков. Каждый пул потоков - это однопоточный пул потоков. Я назначаю задачи каждому пулу потоков в зависимости от условия. Поэтому мне нужно отслеживать потоки. Как я могу это сделать? Могу ли я создат…
31 авг '17 в 00:53
10
ответов
Блок ThreadPoolExecutor, когда очередь заполнена?
Я пытаюсь выполнить много задач, используя ThreadPoolExecutor. Ниже приведен гипотетический пример: def workQueue = new ArrayBlockingQueue<Runnable>(3, false) def threadPoolExecutor = new ThreadPoolExecutor(3, 3, 1L, TimeUnit.HOURS, workQueue)…
10 авг '10 в 04:24
2
ответа
java ThreadPoolExecutor default
Я читал документацию по Oracle для ThreadPoolExecutor и, в частности, об организации очередей на случай, если доступно больше запросов, чем Threads. Однако я не выяснил, какие настройки по умолчанию. Единственное, что я делаю, чтобы создать экземпля…
15 ноя '13 в 10:55
1
ответ
Используя runAsync плагина Grails Exector Plugin, зачем мне нужна транзакция для сохранения объекта Domain?
Вот примерно то, что я делаю в сервисе: runAsync { <some work here> myDomainObject.merge() } Я получаю сообщение об ошибке "Сессия Hibernate не привязана к потоку, и конфигурация не позволяет создавать нетранзакционный сеанс здесь". Я точно зн…
06 окт '13 в 14:50
1
ответ
Xamarin Executor, который принимает Callable
Часть I Привет, я пытаюсь изменить следующий фрагмент кода, чтобы использовать Callable вместо Runnable, потому что я хочу, чтобы функции, которые передаются в Executor, возвращали данные. using Android.App; using Android.OS; using Android.Widget; u…
19 янв '17 в 08:32
8
ответов
Java Executors: как мне установить приоритет задачи?
Есть ли возможность установить приоритет задач, которые выполняются исполнителями? Я нашел некоторые утверждения в JCIP о том, что это возможно, но я не могу найти ни одного примера и не могу найти ничего связанного с документами. От JCIP: Политика …
07 июл '10 в 20:46
2
ответа
Stop Executor, когда Callable возвращает определенный результат
Я бы хотел, чтобы исполнитель не запускал больше объектов Future, даже если они были отправлены исполнителю. Запуск нескольких потоков, хотя Executor все работает нормально, но Executor должен остановиться, когда один из Callable возвращает Boolean …
09 фев '11 в 17:31
2
ответа
Каков оптимальный размер пула потоков для простой программы, выполняющей задачи на базе процессора в Java
Я использую пул потоков для выполнения задач, которые в основном основаны на процессорах с небольшим количеством операций ввода-вывода, размер которых больше, чем число процессоров. Executors.newFixedThreadPool(Runtime.getRuntime().availableProcesso…
18 окт '12 в 09:14