Python Synchronisation Queue

pysyncq is a multiprocessing data structure that is implemented entirely in Python, using only the standard library. It acts to coordinate the activity of separate processes in two domains. Time and Data. Any process that connects to such a queue is able to share and receive messages with all others. Unlike a conventional queue, a message is not removed until it has been read by all connected processes. And any message that is written by one process will be read by all others. A process can wait on the queue for incoming messages from other processes, or to write its own message. Hence, the queue can be used to obtain a measure of synchronised behaviour.

Contents:

• Get started with pysyncq
  • Initialisation
  • Sending messages
  • Reading messages
  • Closing and unlinking
  • Start methods
  • General queue behaviour
  • OS specific behaviour
• pysyncq
  • pysyncq package
• Developer notes
  • Organisation of shared memory
  • Circular buffering of messages
  • Current design limitations
  • Message write and read Serial Numbers

Indices and tables

• Index

• Module Index

• Search Page