1、chan類型

package main
import (
  "fmt"
  "os"
  "os/single"
  "reflect"
  "syscall"
)

func refelectChan(ch interface{}, value interface{}) {
    // 判斷是否為通道類型
    if reflect.ValueOf(ch).Kind() == reflect.Chan {
        // 發(fā)送者
        go func(value interface{}) {
            defer func() {
                fmt.Println("exit-send")
            }()
            // 判斷發(fā)送的消息是否符合通道類型
            if reflect.ValueOf(value).Type().String() == reflect.ValueOf(ch).Type().Elem().String() {
                // 向通道內(nèi)發(fā)送消息
                reflect.ValueOf(ch).Send(reflect.ValueOf(value))
                time.Sleep(time.Second * 5)
                // 關(guān)閉通道
                reflect.ValueOf(ch).Close()
            } else {
                fmt.Println("類型不符合通道定義")
                return
            }

        }(value)
        // 接收者
        go func() {
            defer func() {
                fmt.Println("exit-recv")
            }()
            for {
                // 接收消息，通道關(guān)閉ok為false
                msg, ok := reflect.ValueOf(ch).Recv()
                if ok {
                    fmt.Println(msg)
                } else {
                    fmt.Println("通道已關(guān)閉")
                    return
                }
            }
        }()

    } else {
        fmt.Println("不是通道類型")
        return
    }
}
func mian(){
    var a interface{}
    a = make(chan struct{})
    refelectChan(a, struct{}{})
    // 監(jiān)聽程序退出信號，關(guān)閉服務(wù)后退出
    ch := make(chan os.Signal, 1)
    signal.Notify(ch, syscall.SIGINT, syscall.SIGTERM)
    sig := <-ch
    fmt.Println("退出", sig)

}