by Alex Tkachman
“Fast immutable persistent functional queues for concurrency with Groovy” talks about implementation of functional queues with Groovy++. Here is another article to use these queues to implement several algorithms for processing of asynchronious messages. You can find source code and more examples in the Groovy++ distro.

This article discusses implementing simplified actor, the object which sequentially process asynchroniously coming messages. There are two types of actors

* thread bound actor, which is the one having dedicated message processing thread. The thread is blocked if no messages are available
* pooled actor, which is executed on some thread pool. The beauty of pooled actor is that it does not consume any resources at all if there is no messages to process

Full Story