Связь по принципaм "Многие-к-одному и многие-ко-многим"

Начните получать сообщения на канале, построенном по принципу "многие-к-одному".

In[1]:=

listener = ChannelListen["master"]

Out[1]=

Отправляйте сообщения из нескольких сессий, например, из параллельных ядер на одном и том же компьютере, через канал связи.

In[2]:=

ParallelEvaluate[ChannelSend["master", $KernelID]]

Out[2]=

Полученные сообщения.

In[3]:=

listener["Message", All]

Out[3]=

Диаграмма обмена сообщениями.

In[4]:=

spikey = ImageCrop@ Import["http://www.wolfram.com/spikey/img/spikey.png"];

In[5]:=

Graph[Table[i \[DirectedEdge] 0, {i, listener["MessageID", All]}], VertexShape -> spikey, VertexSize -> .5]

Out[5]=

Прослушивайте сообщения на том же канале связи в нескольких параллельных сессиях.

In[6]:=

ParallelEvaluate[l = ChannelListen["all"]]

Out[6]=

Параллельные ядра отправят свои идентификаторы каналу.

In[7]:=

ParallelEvaluate[ChannelSend["all", $KernelID]]

Out[7]=

Сообщения, полученные слушателями, с их соответствующими идентификаторами ядра.

In[8]:=

ParallelEvaluate[$KernelID -> l["Message", All]]

Out[8]=

Диаграмма обмена сообщениями.

In[9]:=

ParallelEvaluate[$KernelID -> l["Message", All]]; Graph[Flatten[Thread /@ %], VertexShape -> spikey, VertexSize -> .5]

Out[9]=