queue

Aug 21, 2021

Changes in this version

+ var InBufSize = 1

+ var OutBufSize = 1

+ func NewFFQueue(ctx context.Context, pollInterval time.Duration, spawnDeadline time.Duration) *ffQueue

+ func NewThreadPacker(ctx context.Context, maxPackSize int, timeout time.Duration) *threadPacker

+ type CallQueue interface

+ Call func(p peer.ID, t thread.ID, c PeerCall) error

+ Schedule func(p peer.ID, t thread.ID, priority int, c PeerCall) bool

+ type PeerCall func(context.Context, peer.ID, thread.ID) error

+ type ThreadPack struct

+ Peer peer.ID

+ Threads []thread.ID

+ type ThreadPacker interface

+ Add func(pid peer.ID, tid thread.ID)

+ Run func() <-chan ThreadPack