co

README

co

coroutine library

A coroutine library to implement deterministic scheduling of concurrent processes.

Mostly inspired by Rob Pike's recursive state function type in his Lexical Scanning in Go talk.

I use this pattern a lot in the sb library, modeling stream/sink process as recursive functions.

Roadmap

• I/O waiting. channel polling
• threaded scheduler
• prioritized scheduling

Documentation

Index

• type Proc
• type Thread
  • func NewThread[S any, V any](initState S, initProc Proc[V]) *Thread[S, V]
  • func (t *Thread[S, V]) Step() (v V, ok bool)

Types

type Proc

type Proc[V any] func(next *Proc[V]) V

Proc represents a procedure that returns a value and sets the next procedure

type Thread

type Thread[S any, V any] struct {
	// contains filtered or unexported fields
}

Thread represents a state and a procedure

func NewThread

func NewThread[S any, V any](
	initState S,
	initProc Proc[V],
) *Thread[S, V]

NewThread creates a new thread

func (*Thread[S, V]) Step

func (t *Thread[S, V]) Step() (v V, ok bool)

Step execute the thread in single step