diff --git a/examples/consul/go-server/server.go b/examples/consul/go-server/server.go index 798fe7c7b0632bf7d366d4bf500846fd6ced73e9..0e1e1f608e4f112e4e47f74682156103345f80e3 100644 --- a/examples/consul/go-server/server.go +++ b/examples/consul/go-server/server.go @@ -57,7 +57,7 @@ func initSignal() { case syscall.SIGHUP: // reload() default: - go time.AfterFunc(time.Duration(float64(survivalTimeout)*float64(time.Second)), func() { + time.AfterFunc(time.Duration(float64(survivalTimeout)*float64(time.Second)), func() { logger.Warnf("app exit now by force...") os.Exit(1) }) diff --git a/examples/generic/go-client/app/client.go b/examples/generic/go-client/app/client.go index 8d5a1bc5fa6cb186fcf456d385f8dad16b750ea3..dbd4665f5cd8e6740094c00f3cb089a932bb3e51 100644 --- a/examples/generic/go-client/app/client.go +++ b/examples/generic/go-client/app/client.go @@ -35,10 +35,6 @@ import ( _ "github.com/apache/dubbo-go/registry/zookeeper" ) -var ( - survivalTimeout int = 10e9 -) - // they are necessary: // export CONF_CONSUMER_FILE_PATH="xxx" // export APP_LOG_CONF_FILE="xxx" diff --git a/examples/hystrixfilter/dubbo/with-hystrix-go-client/app/client.go b/examples/hystrixfilter/dubbo/with-hystrix-go-client/app/client.go index 0d8d7d2ffd6b7ea5db3831b55fa4dc45ace302c5..e759465f002ed68e6f6faf217f99352b98b3d13a 100644 --- a/examples/hystrixfilter/dubbo/with-hystrix-go-client/app/client.go +++ b/examples/hystrixfilter/dubbo/with-hystrix-go-client/app/client.go @@ -20,9 +20,6 @@ package main import ( "context" "fmt" - "os" - "os/signal" - "syscall" "time" ) @@ -44,10 +41,6 @@ import ( _ "github.com/apache/dubbo-go/registry/zookeeper" ) -var ( - survivalTimeout int = 10e9 -) - // they are necessary: // export CONF_CONSUMER_FILE_PATH="xxx" // export APP_LOG_CONF_FILE="xxx" @@ -102,29 +95,4 @@ func main() { resGot := <-getUser1Chan logger.Infof("[GetUser1] %v", resGot) } - //initSignal() -} - -func initSignal() { - signals := make(chan os.Signal, 1) - // It is not possible to block SIGKILL or syscall.SIGSTOP - signal.Notify(signals, os.Interrupt, os.Kill, syscall.SIGHUP, - syscall.SIGQUIT, syscall.SIGTERM, syscall.SIGINT) - for { - sig := <-signals - logger.Infof("get signal %s", sig.String()) - switch sig { - case syscall.SIGHUP: - // reload() - default: - go time.AfterFunc(time.Duration(survivalTimeout)*time.Second, func() { - logger.Warnf("app exit now by force...") - os.Exit(1) - }) - - // 瑕佷箞fastFailTimeout鏃堕棿鍐呮墽琛屽畬姣曚笅闈㈢殑閫昏緫鐒跺悗绋嬪簭閫€鍑猴紝瑕佷箞鎵ц涓婇潰鐨勮秴鏃跺嚱鏁扮▼搴忓己琛岄€€鍑� - fmt.Println("app exit now...") - return - } - } }