Одновременно отправьте данные в и получите данные от другого рабочего
dataReceived = labSendReceive(rcvWkrIdx,srcWkrIdx,dataSent)
dataReceived = labSendReceive(rcvWkrIdx,srcWkrIdx,dataSent,tag)
| Данные по передающему рабочему, который отправляется рабочему получения; любой MATLAB® тип данных. |
| Данные приняты на рабочем получения. |
|
|
|
|
| Неотрицательное целое число, чтобы идентифицировать данные. |
dataReceived = labSendReceive(rcvWkrIdx,srcWkrIdx,dataSent) отправляет dataSent рабочему, чей labindex rcvWkrIdx, и получает dataReceived от рабочего, чей labindex srcWkrIdx. Значения для аргументов rcvWkrIdx и srcWkrIdx должны быть скаляры. Эта функция концептуально эквивалентна следующей последовательности вызовов:
labSend(dataSent,rcvWkrIdx); dataReceived = labReceive(srcWkrIdx);
с важным исключением, что и отправка и получение данных происходят одновременно. Это может устранить мертвые блокировки, которые могут в противном случае произойти если эквивалентный вызов labSend блокировался бы.
Если rcvWkrIdx пустой массив, labSendReceive не отправляет данные, но только получает. Если srcWkrIdx пустой массив, labSendReceive не получает данные, но только отправляет.
dataReceived = labSendReceive(rcvWkrIdx,srcWkrIdx,dataSent,tag) использует заданный тег для коммуникации. tag может быть любое целое число от 0 к 32767.
Создайте уникальный набор данных по каждому рабочему и передайте данные каждого рабочего один рабочий направо (к следующему более высокому labindex).
Сначала используйте magic функция, чтобы создать уникальную стоимость для различного массива mydata на каждом рабочем.
mydata = magic(labindex)
Worker 1:
mydata =
1
Worker 2:
mydata =
1 3
4 2
Worker 3:
mydata =
8 1 6
3 5 7
4 9 2Задайте рабочего с обеих сторон, так, чтобы каждый рабочий получил данные от рабочего на его “левом”, при отправке данных рабочему на его “праве”, циклическом повторении данных от рабочего конца назад начинающему рабочему.
rcvWkrIdx = mod(labindex, numlabs) + 1; % one worker to the right srcWkrIdx = mod(labindex - 2, numlabs) + 1; % one worker to the left
Передайте данные, отправив mydata каждого рабочего в otherdata следующего рабочего переменная, перенося данные третьего рабочего назад первому рабочему.
otherdata = labSendReceive(rcvWkrIdx,srcWkrIdx,mydata)
Worker 1:
otherdata =
8 1 6
3 5 7
4 9 2
Worker 2:
otherdata =
1
Worker 3:
otherdata =
1 3
4 2Передайте данные следующему рабочему, не перенося данные от последнего рабочего первому рабочему.
if labindex < numlabs; rcvWkrIdx = labindex + 1; else rcvWkrIdx = []; end; if labindex > 1; srcWkrIdx = labindex - 1; else srcWkrIdx = []; end; otherdata = labSendReceive(rcvWkrIdx,srcWkrIdx,mydata)
Worker 1:
otherdata =
[]
Worker 2:
otherdata =
1
Worker 3:
otherdata =
1 3
4 2labBarrier | labindex | labProbe | labReceive | labSend | numlabs