sema_test.go

sema_test.go

package jdksync

import (
	"testing"
	"time"
)

func TestItAll(t *testing.T) {
	s := NewSema()

	for i := 0; i < 10; i++ {
		select {
		case <-s.Wait():
		default:
			t.Fatal("should not have had to wait before calling block!")
		}

		s.Block()

		select {
		case <-s.Wait():
			t.Fatal("blocked - should not have passed beyond wait")
		case <-time.After(time.Second):
		}

		s.Unblock()

		select {
		case <-s.Wait():
		default:
			t.Fatal("should not have had to wait after calling unblock!")
		}
	}
}