Has anyone had any success on running a channel listener in a kernel.
eg
- Create Channel (CreateChannel[“test” ])
- Spin up kernel to process resuls
- Send channel message from another process.
I can not get the channel listener active in this scenario. When I run it from the front end it works but in the kernel it does not. Any suggestions would be appreciated:
list = {1, 2};
ParallelMap[{Print["Processing job: ", #];
listener = ChannelListen["test", myfunc]; Print["listener: ", listener, " kern ", $KernelID, " job ", #]; Pause[60]} &, list]
myfunc[a_Association] := Module[{}, Print["printed from my func", a , " in kern: ", $KernelID] ];
IN ANOTHER SESSION:
ChannelSend[“test”, <|“a” → “hello”, “msg” → RandomReal[]|>]