Dataflow Synchronization

class Producer

meth produceStream(Xs)

X|Xr = Xs

in

{Produce X}

{self produceStream(Xr)}

end

end

class Consumer

meth consumeStream(Xs)

case Xs of X|Xr

then

{Consume X}

{self consumeStream(Xr)}

end

end

end

declare Stream

thread {New Producer produceStream(Stream)} end

thread {New Consumer consumeStream(Stream)} end

Previous slide

Next slide

Back to first slide

View graphic version