Метод getQueue() обеспечивает доступ к базовой очереди блокировки в ThreadPoolExecutor, но это не кажется безопасным. Обход очереди, возвращаемой этой функцией, может пропустить обновления, внесенные в очередь ThreadPoolExecutor. «Метод...

Я использую в своем приложении пулы потоков. Я создал подкласс TreadPoolExecutor и переопределил методы beforeExecute, afterExecute и terminated для статистических целей. Я также реализовал свою собственную ThreadFactory и переопределил метод...

В моей практике нередки случаи, когда разрабатываемое мной программное обеспечение становится большим и сложным, и различные его части используют исполнителей по-своему. С точки зрения производительности было бы лучше использовать разные конфигурации...

У меня есть ряд задач (т.е. Runnable s), которые должен выполнить Executor . Каждая задача требует выполнения определенного условия для продолжения. Мне было бы интересно узнать, есть ли способ каким-то образом настроить Executor для перемещения...

Я использую ExecutorService для реализации 3-поточного пула и CountDownLatch для отслеживания завершения всех потоков для дальнейшей обработки. ExecutorService threadExecutor = Executors.newFixedThreadPool(3); CountDownLatch countDownLatch = new...

Архитектура Spark полностью вращается вокруг концепции исполнителей и ядер. Я хотел бы практически увидеть, сколько исполнителей и ядер работает для моего искрового приложения, работающего в кластере. Я пытался использовать приведенный ниже...

Я запускаю свое приложение Spark на YARN с параметрами: в spark-defaults.conf: spark.master yarn-client spark.driver.cores 1 spark.driver.memory 1g spark.executor.instances 6 spark.executor.memory 1g в yarn-site.xml:...

В моей компании мы собрали очень разнородный кластер YARN + Spark, используя комбинацию старых и новых машин. Поскольку статистика отдельных машин сильно различается, я хотел бы иметь возможность запускать несколько исполнителей на больших машинах....