Refactor timers.go

1 files changed, 45 insertions, 0 deletions

diff --git a/src/signal.go b/src/signal.go
new file mode 100644
index 0000000..96b21bb
--- /dev/null
+++ b/src/signal.go
@@ -0,0 +1,45 @@
+package main
+
+type Signal struct {
+	enabled AtomicBool
+	C       chan struct{}
+}
+
+func NewSignal() (s Signal) {
+	s.C = make(chan struct{}, 1)
+	s.Enable()
+	return
+}
+
+func (s *Signal) Disable() {
+	s.enabled.Set(false)
+	s.Clear()
+}
+
+func (s *Signal) Enable() {
+	s.enabled.Set(true)
+}
+
+func (s *Signal) Send() {
+	if s.enabled.Get() {
+		select {
+		case s.C <- struct{}{}:
+		default:
+		}
+	}
+}
+
+func (s Signal) Clear() {
+	select {
+	case <-s.C:
+	default:
+	}
+}
+
+func (s Signal) Broadcast() {
+	close(s.C) // unblocks all selectors
+}
+
+func (s Signal) Wait() chan struct{} {
+	return s.C
+}