Comunicación muchos-a-uno y muchos-a-muchos

Inicie la escucha en un canal para la comunicación de muchos-a-uno.

In[1]:=

listener = ChannelListen["master"]

Out[1]=

Envíe mensajes al canal desde las sesiones; por ejemplo, desde kérneles paralelos en la misma máquina.

In[2]:=

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

Out[2]=

Los mensajes recibidos.

In[3]:=

listener["Message", All]

Out[3]=

Un diagrama de intercambio de mensajes.

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]=

Comience a escuchar en el mismo canal en múltiples sesiones de kérneles paralelos.

In[6]:=

ParallelEvaluate[l = ChannelListen["all"]]

Out[6]=

Deje que todos los kérneles paralelos envíen sus respectivos ID al canal.

In[7]:=

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

Out[7]=

Los mensajes recibidos por los oyentes, con sus respectivos IDs de kérneles.

In[8]:=

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

Out[8]=

Un diagrama del intercambio.

In[9]:=

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

Out[9]=