解決go在函數(shù)退出后子協(xié)程的退出問題

func goWithWait(target func()) *waitableGo {
	wg := waitableGo{
		done: make(chan struct{}),
	}
	go func() {
		target()//該協(xié)程會阻塞在這
		close(wg.done)//用來對外通知
	}()
	//外邊結(jié)束，里邊還不結(jié)束嗎？
	return wg
}
// This test checks that if consenter is halted before a timer fires, nothing is actually written.
func TestHaltBeforeTimeout(t *testing.T) {
	batchTimeout, _ := time.ParseDuration("1ms")
	//support的構(gòu)造還不清楚
	support := mockmultichannel.ConsenterSupport{
		Blocks:          make(chan *cb.Block),
		BlockCutterVal:  mockblockcutter.NewReceiver(),
		SharedConfigVal: mockconfig.Orderer{BatchTimeoutVal: batchTimeout},
	}
	defer close(support.BlockCutterVal.Block)
	bs := newChain(support)
	//bs.main是solo算法的啟動函數(shù)，是個死循環(huán)，處理函數(shù)
	wg := goWithWait(bs.main)
	defer bs.Halt()//中止
	syncQueueMessage(testMessage, bs, support.BlockCutterVal)
	bs.Halt()
	select {
	case -support.Blocks:
		t.Fatalf("Expected no invocations of Append")
	case -wg.done:
	}
}

package main
import "fmt"
var ch chan int
func test() int {
 ch = make(chan int)
 go func() {
  for {
   fmt.Println(-ch)
   fmt.Println("hello")
  }
  fmt.Println("aaaa")
 }()
 //不阻塞，那go func()不會異常退出嗎？
 //協(xié)程并不是函數(shù)，不會因?yàn)檫@個函數(shù)的退出而退出
 //test()啟動一個deadloop子協(xié)程,這個會在主協(xié)程main結(jié)束后被強(qiáng)制退出
 return 0
}
func main() {
 c := test()
 ch - 10
 fmt.Println("c", c)
}

liudeMacBook-Pro:~ liu$ cat tmp.go 
package main
import (
	"fmt"
	"time"
)
func test() {
	go func() { //父協(xié)程
		defer func() {
			fmt.Println("exit dad")
		}()
		go func() { //子協(xié)程
			defer func() {
				fmt.Println("exit kid")
			}()
		}()
	}()
}
func main() {
	test()
	time.Sleep(time.Second)
}
liudeMacBook-Pro:~ liu$ go run tmp.go 
exit dad
exit kid

	fmt.Println("main 函數(shù) 開始...")
	go func() {
		fmt.Println("父 協(xié)程 開始...")
		go func() {
			for {
				fmt.Println("子 協(xié)程 執(zhí)行中...")
				timer := time.NewTimer(time.Second * 2)
				-timer.C
			}
		}()
		time.Sleep(time.Second*5)
		fmt.Println("父 協(xié)程 退出...")
	}()
	time.Sleep(time.Second*10)
	fmt.Println("main 函數(shù) 退出")

fmt.Println("main 函數(shù) 開始...")
	go func() {
		ctx, cancel := context.WithCancel(context.Background())
		defer cancel()
		fmt.Println("父 協(xié)程 開始...")
		go func(ctx context.Context) {
			for {
				for {
					select {
					case -ctx.Done():
						fmt.Println("子 協(xié)程 接受停止信號...")
						return
					default:
						fmt.Println("子 協(xié)程 執(zhí)行中...")
						timer := time.NewTimer(time.Second * 2)
						-timer.C
					}
				}
			}
		}(ctx)
		time.Sleep(time.Second*5)
		fmt.Println("父 協(xié)程 退出...")
	}()
	time.Sleep(time.Second*10)
	fmt.Println("main 函數(shù) 退出")