/* * @Author: your name * @Date: 2021-08-02 00:02:17 * @LastEditTime: 2021-08-24 23:18:40 * @LastEditors: Please set LastEditors * @Description: In User Settings Edit * @FilePath: \background\test\goroutine_test.go */ package test import ( "context" "sync" "testing" "time" ) func TestWaitGroup(t *testing.T) { var wg sync.WaitGroup wg.Add(2) go func () { time.Sleep(3*time.Second) t.Logf("job 1 done") wg.Done() }() go func () { time.Sleep(2 * time.Second) t.Logf("job 2 done") wg.Done() }() wg.Wait() t.Log("all finish") } func TestChanel(t *testing.T){ exit := make(chan bool) go func () { for { select { case <-exit: t.Logf("exit 1") return case <- time.After(1 * time.Second) : t.Logf("time out ") } } }() go func () { for { select { case <-exit: t.Logf("exit 2") return case <- time.After(1 * time.Second) : t.Logf("time out ") } } }() time.Sleep(5 * time.Second) exit <- true t.Logf("finish") } type TestInherit struct{ context.Context x int32 } func TestTimeoutContext(t * testing.T){ ctx,_ := context.WithTimeout(context.Background(), time.Second * 1) aa := TestInherit{ctx,1} go func (aa *TestInherit) { for { select { case <-aa.Done(): t.Logf("exit") return case <- time.After(5 * time.Second) : t.Logf("time out ") } } }(&aa) time.Sleep(10 * time.Second) } func TestContext(t *testing.T){ ctx,cancel := context.WithCancel(context.Background()) go func () { for { select { case <-ctx.Done(): t.Logf("exit") return case <- time.After(1 * time.Second) : t.Logf("time out ") } } }() go func () { for { select { case <-ctx.Done(): t.Logf("exit") return case <- time.After(1 * time.Second) : t.Logf("time out ") } } }() go func () { for { select { case <-ctx.Done(): t.Logf("exit") return case <- time.After(1 * time.Second) : t.Logf("time out ") } } }() time.Sleep(5 * time.Second) cancel() t.Logf("finish") }