Define a library for Go-style wait groups

Define a data structure and methods to represent a Go-style wait group,
similar to `sync.WaitGroup` (except single-threaded).

Implements a similar interface. Calling `wait` blocks until the wait
group's internal counter gets to 0.

2 files changed, 36 insertions, 0 deletions

diff --git a/src/package.lisp b/src/package.lisp
new file mode 100644
index 0000000..c868d02
--- /dev/null
+++ b/src/package.lisp
@@ -0,0 +1,9 @@
+(defpackage :wait-group
+  (:nicknames :wg)
+
+  (:use :cl)
+
+  (:export #:make-wait-group
+           #:add
+           #:done
+           #:wait))
diff --git a/src/wait-group.lisp b/src/wait-group.lisp
new file mode 100644
index 0000000..35bb982
--- /dev/null
+++ b/src/wait-group.lisp
@@ -0,0 +1,27 @@
+(in-package :wait-group)
+
+(defclass wait-group ()
+  ((counter
+     :initform 0
+     :accessor counter)))
+
+(defun make-wait-group ()
+  (make-instance 'wait-group))
+
+(defgeneric add (wait-group &optional amount)
+  (:documentation ""))
+
+(defmethod add ((wait-group wait-group) &optional (amount 1))
+  (incf (counter wait-group) amount))
+
+(defgeneric done (wait-group)
+  (:documentation ""))
+
+(defmethod done ((wait-group wait-group))
+  (decf (counter wait-group)))
+
+(defgeneric wait (wait-group)
+  (:documentation ""))
+
+(defmethod wait ((wait-group wait-group))
+  (loop until (= (counter wait-group) 0)))