Kioto

Concurrency library for Zig

Features

Orthogonal abstractions for concurrency: runtime × fibers × futures:

• Runtime
  • Multi-threaded ConcurrentRuntime
  • Deterministic ManualRuntime for testing and debugging
  • Timers
• Functional futures with combinators
  • Constructors
    • makeContract
    • spawn
    • ready
    • unit
  • Combinators
    • Sequential composition
      • map – maps a value of type T to type U
      • flatten – flattens nested futures (for asynchronous mappers)
      • flatMap – Map + Flatten
      • via – sets runtime for mappers
      • after – sets delay
    • Parallel composition
      • both
      • first
  • Terminators
    • get – unwraps value from future, blocks thread
    • await – unwraps value from future, does not block thread
• Stackful fibers with stack pooling
  • Api
    • yield
    • sleepFor
    • suspendFiber
    • spawn
  • Synchronization
    • Mutex
    • Event
    • WaitGroup
    • BufferedChannel
    • UnbufferedChannel

Requirements

Build

# Clone repo
git clone https://github.com/Tau-0/kioto.git
cd kioto
# Run playground
zig build -Doptimize=ReleaseFast playground
# Run tests
zig build test

Thanks

Roman Lipovsky for the amazing course "Theory and Practice of Concurrency"