Communicating with multiple cores

[matrix]

Hi All,

I want to connect two producer threads with one worker
thread, and it should be non-blocking. Just can't figure out
how to do it. Code as below in the worker would block, right?

Thanks for hints

Code: Select all

void worker(chanend e1,chanend e2)
{
unsigned data1;
unsigned data2;
.

while(1)
{
 e1:>data1;
 e2:>data2;
 //process data
}

}

(Mod edit: Edited subject)

[matrix]

select statement, have overlooked it.