Tandem🔗ℹ

Jan Dvořák <mordae@anilinux.org>

Cooperative Communication Framework

When communicating with a remote party, one often needs to run multiple parallel queries from different threads while monitoring the communication for asynchronous notifications. The simple way to implement this pattern is to spawn a dedicated background thread that takes care of the communication and acts as a request-response server for other local threads.

Tandem realizes this pattern using events and channels within the threads participating in the communication, thus eliminating the background thread.

Tandem works as a middleware of sorts. You need to supply a backend event that produces tagged messages from the remote party and a procedure that sends our tagged messages.

Note that even though tandem itself is thread-safe and in fact designed to be shared among multiple threads, it does not ensure that the actual transmitting and receiving code is called from one thread only. It’s up to you to ensure that it will operate correctly under those conditions.

The first argument of the transmit procedure is a message tag, that uniquely represents a call/return pair or non-uniquely identifies an out-of-band notification. The other argument is the payload.

The same scheme applies to receive-any-evt: it’s first result value represents a tag and the second the payload.

As an example, we create a simple FIFO echo server that does not really communicate with anything external, but imagine that we used a TCP socket instead of the asynchronous channel.

Please note that creating such event registers a new channel that gets removed only after a garbage collection cycle. Thus creating many such events in a tight loop will be incredibly inefficient.

Since we are using an asynchronous queue and nobody else tries to outrun us, we can retrieve the value from tandem-transmit above.