go-wait

Note

The current situation is unstable.

Import

wait "github.com/yimtcode/go-wait"

Example

1.Wait

func TestWait_Wait(t *testing.T) {
	key, value := 0x1, 999
	w := NewWait()
	w.SetTimeout(10 * time.Second)

	// 方案1
	w.SetAutoInit(true, 0)
	// 方案2
	//w.InitKey(0, key)

	go func() {
		time.AfterFunc(2*time.Second, func() {
			w.TriggerValue(key, value)
		})
	}()
	r, err := w.Wait(key)
	if err != nil {
		t.Fatal(err.Error())
	}
	t.Log(r)
}

2.WaitAll

func TestWait_WaitAll(t *testing.T) {
	keys := []interface{}{1, 2, 3}
	values := []interface{}{11, 22, 33}

	w := NewWait()
	w.SetTimeout(10 * time.Second)
	w.InitKey(keys...)
	go func() {
		time.AfterFunc(1*time.Second, func() {
			w.TriggerValue(keys[0], values[0])
		})
		time.AfterFunc(2*time.Second, func() {
			w.TriggerValue(keys[1], values[1])
		})
		time.AfterFunc(3*time.Second, func() {
			w.TriggerValue(keys[2], values[2])
		})
	}()
	r, err := w.WaitAll(keys...)
	if err != nil {
		t.Fatal(err.Error())
	}

	v1, _ := r.GetInt(keys[0])
	v2, _ := r.GetInt(keys[1])
	v3, _ := r.GetInt(keys[2])
	t.Logf("%d %d %d\n", v1, v2, v3)
}

3.WaitAny

func TestWait_WaitAny(t *testing.T) {
	keys := []interface{}{1, 2, 3}
	values := []interface{}{11, 22, 33}

	w := NewWait()
	w.SetTimeout(10 * time.Second)
	w.InitKey(keys...)
	go func() {
		time.AfterFunc(2*time.Second, func() {
			w.TriggerValue(keys[0], values[0])
		})
		time.AfterFunc(1*time.Second, func() {
			w.TriggerValue(keys[1], values[1])
		})
		time.AfterFunc(3*time.Second, func() {
			w.TriggerValue(keys[2], values[2])
		})
	}()
	r, err := w.WaitAny(keys...)
	if err != nil {
		t.Fatal(err.Error())
	}

	v1, b1 := r.GetInt(keys[0])
	v2, b2 := r.GetInt(keys[1])
	v3, b3 := r.GetInt(keys[2])
	t.Logf("key1: %d,%t key2: %d,%t key3: %d,%t\n", v1, b1, v2, b2, v3, b3)
}

Change

• v0.0.4
  • Add auto init of event.
• v0.0.3
  • Add buffer in the event.
• v0.0.2
  • Add InitKey.
• v0.0.1