Отправьте и опросите данные между клиентом и рабочими
PollableDataQueue
включает синхронную отправку и опрос для данных или сообщений между рабочими и клиентом в параллельном пуле, в то время как расчет выполняется. Можно получить промежуточные значения и прогресс расчета.
Чтобы отправить данные от параллельного рабочего пула назад клиенту, сначала создайте PollableDataQueue
в клиенте. Передайте этот PollableDataQueue
в parfor
- цикл или другое построение языка параллельного программирования, такой как parfeval
. От рабочих вызвать send
передать данные обратно клиенту. В клиенте использовать poll
получать результат сообщения или данных, отправленных от рабочего.
Можно вызвать send
от рабочего или клиента, который создает PollableDataQueue
, при необходимости.
Можно создать очередь на рабочих и передать ее обратно клиенту, чтобы включить коммуникацию в обратном направлении. Однако вы не можете отправить очередь от одного рабочего другому. Используйте spmd
, labSend
, или labReceive
вместо этого.
В отличие от всех других объектов указателя, PollableDataQueue
и DataQueue
экземпляры действительно остаются связанными, когда они отправляются рабочим.
создает объект, который может использоваться, чтобы отправить и опросить относительно сообщений (или данные) от различных рабочих. Создайте p
=
parallel.pool.PollableDataQueuePollableDataQueue
на рабочем или клиенте, где вы хотите получить данные.
gcp
| labReceive
| labSend
| parallel.pool.DataQueue
| parfeval
| parfevalOnAll
| parfor
| poll
| send