Описание тега phaser

Описание тега Вопросы с тегом
Представленный в Java 7, Phaser представляет собой повторно используемый барьер синхронизации, аналогичный по функциональности CyclicBarrier и CountDownLatch, но поддерживающий более гибкое использование.
1 ответ

Как создать цепочку / слой Phasers

Я пишу многопоточное приложение, которое использует Phaser, чтобы знать, когда закончить работу. Проблема в том, что в ExecutorCompletionService может быть даже 100 тыс. Потоков в очереди, но максимальное число незапланированных сторон в Phaser равн…
30 дек '12 в 18:07
1 ответ

Где использовать барьерный рисунок в Java?

Я только что прочитал Javadoc о Phaser там и есть вопрос об использовании этого класса. Javadoc предоставляет образец, но как насчет реального примера? Где такой барьер реализации может быть полезен на практике?
22 фев '15 в 15:03
0 ответов

Пример синхронизатора Phaser на Java

Я только что прочитал javadocs о phaser, и теперь есть смысл спросить о том, применяется ли реализация барьера в самой JDK (я считаю, JDK7). Как Phaser JavaDoc заявил Фазеры могут также использоваться задачами, выполняющимися в ForkJoinPool Итак, я …
26 фев '15 в 11:55
6 ответов

Гибкий CountDownLatch?

Я дважды сталкивался с проблемой, когда поток-производитель создает N рабочих элементов, отправляет их ExecutorService и затем необходимо дождаться, пока все N элементов будут обработаны. Предостережения N не известен заранее. Если бы это было так, …
28 окт '09 в 09:52
3 ответа

Гибкая CountDownLatch не может использовать Phaser из-за ограничения

Я получаю большой файл с N записями. Для каждой записи я создаю новую тему. Мне нужно дождаться завершения всех N потоков. Сначала я использовал Phaser, но его реализация ограничена партиями в 65 тысяч человек. Итак, взрывается, потому что N может б…
28 окт '15 в 20:02
2 ответа

Как я могу узнать, когда последняя партия запускает Phaser.arrive()?

Дано: Executor executor = ...; Phaser phaser = new Phaser(n); for (int i=0; i<n; ++i) { Runnable task = new Runnable() { public void run() { phaser.arriveAndDeregister(); if (lastTask) doSomething(this); } } // run tasks using a thread-pool (orde…
27 сен '11 в 18:06
1 ответ

Экземпляры Phaser и Spring MVC

У меня есть весенний @Controller, у которого есть отображение запроса. Когда к нему отправляются запросы, он создает отложенный результат и запускает метод в классе делегатора. В контроллере: @ResponseBody @RequestMapping(MenuModelCodes.MENU_NAME) D…
18 июн '14 в 13:24
1 ответ

Проблемы с фазером (использование JSR166y с последней версией JDK версии 6)

Итак, у меня есть этот Phaser, который действительно гибкий, но, похоже, я что-то упустил. Я успешно использовал CyclicBarrier, но теперь я также хочу что-то более гибкое, как я уже сказал. Итак, вот код:Объявления: private static final CountDownLat…
04 окт '11 в 17:01
2 ответа

Использование синхронизации фазера

Общий вопрос Хорошо известно, что Phaser можно использовать для синхронизации времени запуска всех задач, как указано в JavaDocs и этом блоге Никласа Шлимма. Никлас нарисовал довольно понятное изображение синхронизации: |Phaser |Phaser |Phaser | Tas…
11 май '16 в 08:44
0 ответов

Ввод мыши не работает после перенаправления в инструментах Chrome Dev

Я занимаюсь разработкой веб-приложения на javascript с использованием Phaser и Firebase. Когда в Chrome включены средства разработки, если пользователь входит в Facebook через авторизацию Firebase, используя перенаправление, по возвращении в мое при…
01 мар '19 в 22:00
1 ответ

ForkJoinPool, Phaser и управляемая блокировка: в какой степени они работают против тупиков?

Этот небольшой фрагмент кода никогда не заканчивается на jdk8u45 и используется для правильного завершения на jdk8u20: public class TestForkJoinPool { final static ExecutorService pool = Executors.newWorkStealingPool(8); private static volatile long…
22 май '15 в 09:12
1 ответ

Регистрация потока в Phaser

Я узнаю о Фазере. При этом я столкнулся с проблемой. Ниже приведен код, который у меня есть, public class RunnableTask implements Runnable { private Phaser phaser; public RunnableTask(Phaser phaser) { this.phaser = phaser; this.phaser.register(); //…
26 ноя '18 в 03:19
1 ответ

Phaser Class и Tiering

Согласно javadoc, в Phaser учебный класс, Фазеры могут быть многоуровневыми (т. Е. Построенными в древовидных структурах) для уменьшения конкуренции. Вместо этого можно настроить фазеры с большим количеством сторон, которые в противном случае столкн…
30 май '13 в 13:00
0 ответов

Как обеспечить выполнение исполняемых файлов в последовательном порядке, используя фазер

У меня есть список исполняемых файлов, которые отправляются в Phaser для выполнения, но они не выполняются в порядке их вызова. Например, если я отправляю два запускаемых файла в фазер, он должен вывести "тестирование 0, тестирование 1", но иногда в…
16 авг '15 в 15:02
1 ответ

Обратный вызов java.util.concurrent.Phaser после завершения фазы

Я расследую Phaser от java.util.concurrent пакет и я написал пример кода: public class ThreadsApp { public static void main(String[] args) { Phaser phaser = new Phaser(1); new Thread(new PhaseThread(phaser, "PhaseThread 1")).start(); new Thread(new …
27 янв '17 в 12:40
0 ответов

Проект Cordova+Phaser работает на браузере, а не на мобильном

У меня проблемы с отладкой примера приложения Cordova+Phaser. Я читал этот аналогичный пост, но проблемы кажутся другими (я не думаю, что у меня проблемы с загрузкой ресурсов). Я использую тот же код, что и этот пример phaser-ce (phaser2). Он работа…
19 фев '19 в 03:11
1 ответ

Phaser - как использовать его как CountDownLatch(1)?

Я понимаю, я мог бы просто использовать CountDownLatch непосредственно, однако, в качестве упражнения и понять Phaser лучше, я хотел бы использовать его вместо COuntDownLatch, Таким образом, я бы создал N число ожидающих и один поток, который должен…
09 авг '17 в 20:38
3 ответа

Понимание фазера в Java с примером

Я пытаюсь понять Фазер в Java. Я написал пример, который застрял заранее, ожидая прибытия других сторон. Насколько я понимаю, Phaser используется как барьер для многократного использования потоков (в отличие от CountdownLatch, который нельзя использ…
12 авг '15 в 04:26
1 ответ

Проблема множественного параллелизма с будущим объектом

Я пытаюсь порождать несколько потоков и помещать их в список по мере их выполнения. Когда они завершат свою обработку, я бы хотел собрать их результаты для презентации. Таким образом, у меня может быть список, содержащий много потоков, а затем, как …
30 апр '14 в 00:24
1 ответ

Загрузка плагинов сцены в Phaser 3

Новичок в Фазере. Я использую Phaser 3.16.2 и плагины с https://github.com/rexrainbow/phaser3-rex-notes. Когда я загружаю плагин в метод preload() первой сцены (Docs), а затем использую его в той же сцене в методе create(), он работает нормально. Но…
24 фев '19 в 12:25