Inter-Thread Messaging with Send/Receive

network receive

HTTP request handler

while (systemActive) {
object = GetNextClientRequest();

find object in cache or Web server

while(more data in object) {

currentThread->receive(data);

transmit data to client;

}

}

file/cache manager

network send

get request for object from thread;

while(more data in object) {

read data from object;

thread->send(data);

}

This example illustrates use of blocking send/receive primitives to pass a stream of messages or commands to a specific thread, connection, or “port”.

Previous slide

Next slide

Back to first slide

View graphic version