Отправьте данные от рабочего клиенту, использующему очередь данных
send( отправляет сообщение или данные со значением pollablequeue, data)data к parallel.pool.PollableDataQueue заданный pollablequeue. Получите результат с помощью poll(pollablequeue), и возвратите data как ответ.
Используйте send и poll функции вместе с помощью pollable очереди данных, чтобы передать и получить сообщения или данные от различных рабочих.
parfor- Цикл и Отправка сообщение на ОчередиСоздайте DataQueue, и вызовите afterEach.
q = parallel.pool.DataQueue; afterEach(q, @disp);
parfor- цикл, и отправляет сообщение. Незаконченное сообщение передается afterEach функция, в этом примере @disp.
parfor i = 1:3 send(q, i); end;
1
2
3Для получения дополнительной информации о прислушивании к данным с помощью DataQueue, смотрите afterEach.
parfor- цикл и Опрос для РезультатаСоздайте PollableDataQueue.
p = parallel.pool.PollableDataQueue;
parfor- цикл, и отправляет сообщение, такое как данные со значением 1. parfor i = 1 send(p, i); end
poll(p)
1
Для получения дополнительной информации о получении данных с помощью PollableDataQueue, смотрите poll.
parfor Ожидайте панель Используя Data QueueЭтот пример показывает функцию, которая создает parfor waitbar. Создайте DataQueue, и используйте afterEach чтобы задать функцию, чтобы выполниться каждый раз, очередь получает данные. Этот пример вызывает подфункцию, которая обновляет панель ожидания.
Создайте parfor- цикл, чтобы выполнить в вычислительном отношении требовательную задачу в MATLAB®. Используйте send отправить некоторые фиктивные данные по каждой итерации parfor- цикл. Когда очередь получает данные, afterEach вызовы nUpdateWaitbar в клиенте MATLAB, и можно наблюдать прогресс панели ожидания.
function a = parforWaitbar D = parallel.pool.DataQueue; h = waitbar(0, 'Please wait ...'); afterEach(D, @nUpdateWaitbar); N = 200; p = 1; parfor i = 1:N a(i) = max(abs(eig(rand(400)))); send(D, i); end function nUpdateWaitbar(~) waitbar(p/N, h); p = p + 1; end end
