How to use Status method of interrupt_handler Package

...103			}104			w.updateSeed()105			w.computeSuccinctMode(len(suites))106			for idx := range suites {107				if w.interruptHandler.Status().Interrupted {108					return109				}110				deltaTracker.WillRun(suites[idx])111				suites[idx] = w.compileAndRun(suites[idx], additionalArgs)112			}113			color := "{{green}}"114			if suites.CountWithState(internal.TestSuiteStateFailureStates...) > 0 {115				color = "{{red}}"116			}117			fmt.Fprintln(coloredStream, formatter.F(color+"\nDone.  Resuming watch...{{/}}"))118			messages, err := internal.FinalizeProfilesAndReportsForSuites(suites, w.cliConfig, w.suiteConfig, w.reporterConfig, w.goFlagsConfig)119			command.AbortIfError("could not finalize profiles:", err)120			for _, message := range messages {121				fmt.Println(message)122			}123		case <-w.interruptHandler.Status().Channel:124			return125		}126	}127}128func (w *SpecWatcher) compileAndRun(suite internal.TestSuite, additionalArgs []string) internal.TestSuite {129	suite = internal.CompileSuite(suite, w.goFlagsConfig)130	if suite.State.Is(internal.TestSuiteStateFailedToCompile) {131		fmt.Println(suite.CompilationError.Error())132		return suite133	}134	if w.interruptHandler.Status().Interrupted {135		return suite136	}137	suite = internal.RunCompiledSuite(suite, w.suiteConfig, w.reporterConfig, w.cliConfig, w.goFlagsConfig, additionalArgs)138	internal.Cleanup(w.goFlagsConfig, suite)139	return suite140}141func (w *SpecWatcher) computeSuccinctMode(numSuites int) {142	if w.reporterConfig.Verbosity().GTE(types.VerbosityLevelVerbose) {143		w.reporterConfig.Succinct = false144		return145	}146	if w.flags.WasSet("succinct") {147		return148	}...

...14			interruptHandler = interrupt_handler.NewInterruptHandler(500*time.Millisecond, nil)15			DeferCleanup(interruptHandler.Stop)16		})17		It("eventually closes the interrupt channel to signal an interrupt has occurred", func() {18			status := interruptHandler.Status()19			Ω(status.Interrupted).Should(BeFalse())20			Eventually(status.Channel).Should(BeClosed())21			Ω(interruptHandler.Status().Interrupted).Should(BeTrue())22		})23		It("notes the cause as 'Interrupted By Timeout'", func() {24			status := interruptHandler.Status()25			Eventually(status.Channel).Should(BeClosed())26			cause := interruptHandler.Status().Cause27			Ω(cause).Should(Equal(interrupt_handler.InterruptCauseTimeout))28			Ω(interruptHandler.InterruptMessageWithStackTraces()).Should(HavePrefix("Interrupted by Timeout\n\n"))29			Ω(interruptHandler.InterruptMessageWithStackTraces()).Should(ContainSubstring("Here's a stack trace"))30		})31		It("repeatedly triggers an interrupt every 1/10th of the registered timeout", func() {32			status := interruptHandler.Status()33			Ω(status.Interrupted).Should(BeFalse())34			Eventually(status.Channel).Should(BeClosed())35			status = interruptHandler.Status()36			Ω(status.Channel).ShouldNot(BeClosed())37			Eventually(status.Channel).Should(BeClosed())38		})39	})40	Describe("Interrupting when another Ginkgo process has aborted", func() {41		var client parallel_support.Client42		BeforeEach(func() {43			_, client, _ = SetUpServerAndClient(2)44			interruptHandler = interrupt_handler.NewInterruptHandler(0, client)45			DeferCleanup(interruptHandler.Stop)46		})47		It("interrupts when the server is told to abort", func() {48			status := interruptHandler.Status()49			Consistently(status.Channel).ShouldNot(BeClosed())50			client.PostAbort()51			Eventually(status.Channel).Should(BeClosed())52		})53		It("notes the correct cause and returns an interrupt message that does not include the stacktrace ", func() {54			status := interruptHandler.Status()55			client.PostAbort()56			Eventually(status.Channel).Should(BeClosed())57			status = interruptHandler.Status()58			Ω(status.Cause).Should(Equal(interrupt_handler.InterruptCauseAbortByOtherProcess))59			Ω(interruptHandler.InterruptMessageWithStackTraces()).Should(HavePrefix("Interrupted by Other Ginkgo Process"))60			Ω(interruptHandler.InterruptMessageWithStackTraces()).ShouldNot(ContainSubstring("Here's a stack trace"))61		})62	})63})...

...49	handler.cause = cause50	handler.lock.Unlock()51	handler.triggerInterrupt <- true52}53func (handler *FakeInterruptHandler) Status() interrupt_handler.InterruptStatus {54	handler.lock.Lock()55	defer handler.lock.Unlock()56	return interrupt_handler.InterruptStatus{57		Interrupted: handler.interrupted,58		Channel:     handler.c,59		Cause:       handler.cause,60	}61}62func (handler *FakeInterruptHandler) SetInterruptPlaceholderMessage(message string) {63	handler.lock.Lock()64	defer handler.lock.Unlock()65	handler.interruptPlaceholderMessage = message66}67func (handler *FakeInterruptHandler) ClearInterruptPlaceholderMessage() {68	handler.lock.Lock()69	defer handler.lock.Unlock()70	handler.interruptPlaceholderMessage = ""...

1import (2func main() {3    sigs := make(chan os.Signal, 1)4    signal.Notify(sigs, os.Interrupt)5    go func() {6        fmt.Println("Interrupt signal received")7        os.Exit(1)8    }()9    fmt.Println("Working...")10    time.Sleep(time.Second)11    fmt.Println("Done")12}

1import (2func main() {3    handler := NewInterruptHandler()4    interrupt := make(chan os.Signal, 1)5    handler.Register(interrupt)6    handler.Start()7    for {8        select {9            if handler.Status() {10                fmt.Println("Interrupt handler is busy")11                time.Sleep(1 * time.Second)12            } else {13                fmt.Println("Interrupt handler is not busy")14                os.Exit(0)15            }16            fmt.Println("No interrupt")17            time.Sleep(1 * time.Second)18        }19    }20}21import (