A Synchronisation Facility for a Stream Processing Coordination Language

Abstract

In this thesis we present the AstraKahn project that aims to provide environment for stream processing applications with an automatic resource and concurrency management based on communication demand. At the moment the work on the thesis started, the project was at an early stage and there existed no software implementation. The aim of my work is to implement a stream synchronisation facility called synchroniser which is a part of the AstraKahn concept. Synchronisers are programmed in a dedicated language. The thesis focuses on the implementation of the language compiler to be integrated into the runtime system prototype being developed in parallel. AstraKahn structures streaming networks using a xed set of wiring patterns, including the serial replication. This pattern dynamically replicates its operand network conceptually in nitely many times and wires the replicas in a chain. AstraKahn provides an approach to extract messages from the chain based on the concept of xed point. The thesis explores the role of synchronisers in forming from a serial replication pipeline.