diff options
| author | Sam Anthony <sam@samanthony.xyz> | 2024-08-17 22:49:38 -0400 |
|---|---|---|
| committer | Sam Anthony <sam@samanthony.xyz> | 2024-08-17 22:49:38 -0400 |
| commit | c71fb555b23178d2abeaee2a3a5eeb6f2db604aa (patch) | |
| tree | 7e633b57652e47265fc7222011f165a03ec96f11 /share.go | |
| parent | d858988ee600b273d2120c0d09cdaf7d78395157 (diff) | |
| download | gui-c71fb555b23178d2abeaee2a3a5eeb6f2db604aa.zip | |
move shared data structures to external module
Diffstat (limited to 'share.go')
| -rw-r--r-- | share.go | 53 |
1 files changed, 0 insertions, 53 deletions
diff --git a/share.go b/share.go deleted file mode 100644 index 36b903b..0000000 --- a/share.go +++ /dev/null @@ -1,53 +0,0 @@ -package gui - -// sharedVal is a concurrent interface to a piece of shared data. -// -// A client can read the data by sending a channel via request, and the stored value will -// be sent back via the channel. The client is responsible for closing the channel. -// -// The stored value can be changed by sending the new value via set. Requests block until -// the first value is received on set. -// -// A sharedVal should be closed after use. -type sharedVal[T any] struct { - request chan<- chan T - set chan<- T -} - -func newSharedVal[T any]() sharedVal[T] { - request := make(chan chan T) - set := make(chan T) - go func() { - val := <-set // wait for initial value - for { - select { - case v, ok := <-set: - if !ok { // closed - return - } - val = v - case req, ok := <-request: - if !ok { // closed - return - } - go func() { // don't wait for client to receive - req <- val - }() - } - } - }() - return sharedVal[T]{request, set} -} - -// get makes a synchronous request and returns the stored value. -func (sv sharedVal[T]) get() T { - c := make(chan T) - defer close(c) - sv.request <- c - return <-c -} - -func (sv sharedVal[T]) close() { - close(sv.request) - close(sv.set) -} |