How to use Stop method of interrupt_handler Package

...94				break SUITE_LOOP95			}96			suites[suiteIdx] = suite97			if r.interruptHandler.Status().Interrupted {98				opc.StopAndDrain()99				break OUTER_LOOP100			}101			if suites[suiteIdx].State.Is(internal.TestSuiteStateSkippedDueToEmptyCompilation) {102				fmt.Printf("Skipping %s (no test files)\n", suite.Path)103				continue SUITE_LOOP104			}105			if suites[suiteIdx].State.Is(internal.TestSuiteStateFailedToCompile) {106				fmt.Println(suites[suiteIdx].CompilationError.Error())107				if !r.cliConfig.KeepGoing {108					opc.StopAndDrain()109				}110				continue SUITE_LOOP111			}112			if suites.CountWithState(internal.TestSuiteStateFailureStates...) > 0 && !r.cliConfig.KeepGoing {113				suites[suiteIdx].State = internal.TestSuiteStateSkippedDueToPriorFailures114				opc.StopAndDrain()115				continue SUITE_LOOP116			}117			if !endTime.IsZero() {118				r.suiteConfig.Timeout = endTime.Sub(time.Now())119				if r.suiteConfig.Timeout <= 0 {120					suites[suiteIdx].State = internal.TestSuiteStateFailedDueToTimeout121					opc.StopAndDrain()122					continue SUITE_LOOP123				}124			}125			suites[suiteIdx] = internal.RunCompiledSuite(suites[suiteIdx], r.suiteConfig, r.reporterConfig, r.cliConfig, r.goFlagsConfig, additionalArgs)126		}127		if suites.CountWithState(internal.TestSuiteStateFailureStates...) > 0 {128			if iteration > 0 {129				fmt.Printf("\nTests failed on attempt #%d\n\n", iteration+1)130			}131			break OUTER_LOOP132		}133		if r.cliConfig.UntilItFails {134			fmt.Printf("\nAll tests passed...\nWill keep running them until they fail.\nThis was attempt #%d\n%s\n", iteration+1, orcMessage(iteration+1))135		} else if r.cliConfig.Repeat > 0 && iteration < r.cliConfig.Repeat {...

...11	var interruptHandler *interrupt_handler.InterruptHandler12	Describe("Timeout interrupts", func() {13		BeforeEach(func() {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"))...

...23	}24	handler.registerForInterrupts()25	return handler26}27func (handler *FakeInterruptHandler) Stop() {28	close(handler.stop)29}30func (handler *FakeInterruptHandler) registerForInterrupts() {31	go func() {32		for {33			select {34			case <-handler.triggerInterrupt:35			case <-handler.stop:36				return37			}38			handler.lock.Lock()39			handler.interrupted = true40			handler.emittedInterruptPlaceholderMessage = handler.interruptPlaceholderMessage41			close(handler.c)...

1import (2func main() {3    stop := make(chan os.Signal, 1)4    signal.Notify(stop, syscall.SIGINT, syscall.SIGTERM)5    go func() {6        fmt.Println("Interrupted")7        os.Exit(0)8    }()9    for {10        fmt.Println("Running")11        time.Sleep(1 * time.Second)12    }13}

1import (2type interrupt_handler struct {3    stop      chan struct{}4}5func new_interrupt_handler() *interrupt_handler {6    return &interrupt_handler{7        interrupt: make(chan os.Signal, 1),8        stop:      make(chan struct{}),9    }10}11func (h *interrupt_handler) Start() {12    signal.Notify(h.interrupt, os.Interrupt, syscall.SIGTERM)13    go func() {14        close(h.stop)15    }()16}17func (h *interrupt_handler) Stop() {18}19func main() {20    handler := new_interrupt_handler()21    handler.Start()22    defer handler.Stop()23    fmt.Println("Press Ctrl+C to stop")24    for {25        select {26        }27    }28}29import (30func main() {31    ctx, cancel := context.WithCancel(context.Background())32    defer cancel()33    go func() {34        sig := make(chan os.Signal, 1)35        signal.Notify(sig, os.Interrupt, syscall.SIGTERM)36        cancel()37    }()38    fmt.Println("Press Ctrl+C to stop")39    <-ctx.Done()40}41import (42func main() {43    ctx, cancel := context.WithCancel(context.Background())44    defer cancel()45    go func() {46        sig := make(chan os.Signal, 1)47        signal.Notify(sig, os.Interrupt, syscall.SIGTERM)48        cancel()49    }()50    fmt.Println("Press Ctrl+C to stop")51    <-ctx.Done()52}53import (54func main() {55    ctx, cancel := context.WithCancel(context.Background())56    defer cancel()57    go func() {58        sig := make(chan os.Signal, 1

1import (2func main() {3    interrupt_handler := NewInterruptHandler()4    interrupt_handler.Stop()5    fmt.Println("Exiting...")6}7import (8func main() {9    interrupt_handler := NewInterruptHandler()10    interrupt_handler.Stop()11    fmt.Println("Exiting...")12}13import (14func main() {15    interrupt_handler := NewInterruptHandler()16    interrupt_handler.Stop()17    fmt.Println("Exiting...")18}19import (20func main() {21    interrupt_handler := NewInterruptHandler()22    interrupt_handler.Stop()23    fmt.Println("Exiting...")24}25import (26func main() {27    interrupt_handler := NewInterruptHandler()28    interrupt_handler.Stop()29    fmt.Println("Exiting...")30}31import (32func main() {33    interrupt_handler := NewInterruptHandler()34    interrupt_handler.Stop()35    fmt.Println("Exiting...")36}37import (38func main() {39    interrupt_handler := NewInterruptHandler()40    interrupt_handler.Stop()41    fmt.Println("Exiting...")42}43import (44func main() {45    interrupt_handler := NewInterruptHandler()

1import (2func main() {3	interrupt := interrupt_handler.New()4	interrupt_channel := make(chan os.Signal, 1)5	signal.Notify(interrupt_channel, os.Interrupt, syscall.SIGTERM)6	go interrupt.Start(interrupt_channel)7	time.Sleep(10 * time.Second)8	interrupt.Stop()9	fmt.Println("done")10}11import (12func main() {13	interrupt := interrupt_handler.New()14	interrupt_channel := make(chan os.Signal, 1)15	signal.Notify(interrupt_channel, os.Interrupt, syscall.SIGTERM)16	go interrupt.Start(interrupt_channel)17	time.Sleep(10 * time.Second)18	interrupt.Stop()19	fmt.Println("done")20}21import (22func main() {23	interrupt := interrupt_handler.New()24	interrupt_channel := make(chan os.Signal, 1)25	signal.Notify(interrupt_channel, os.Interrupt, syscall.SIGTERM)26	go interrupt.Start(interrupt_channel)27	time.Sleep(10 * time.Second)28	interrupt.Stop()29	fmt.Println("done")30}31import (

1import (2func main() {3    fmt.Println("STARTING")4    interrupt_handler := golinterrupt.NewInterruptHandler()5    interrupt_handler.Start()6    fmt.Println("STARTED")7    for {8        if interrupt_handler.Stop() {9            fmt.Println("STOPPING")10        }11    }12    fmt.Println("STOPPED")13}14NOTE: This is a part of gol (GoLang) package, you can find it in

1import (2func main() {3	interrupt_handler := interrupt_handler.NewInterruptHandler()4	interrupt_handler.RegisterCallback(func() {5		fmt.Println("Interrupt Received")6	})7	interrupt_handler.Start()8}

1import "fmt"2func main() {3    interrupt_handler := InterruptHandler{}4    interrupt_handler.Start()5    fmt.Println("Press Ctrl+C to stop the program")6    interrupt_handler.Wait()

1import (2func main() {3	interrupt_handler := interrupt_handler{}4	interrupt_handler.Start()5	time.Sleep(5 * time.Second)6	interrupt_handler.Stop()7	fmt.Println("Exiting main")8}9import (10func main() {11	interrupt_handler := interrupt_handler{}12	interrupt_handler.Start()13	time.Sleep(5 * time.Second)14	interrupt_handler.Stop()15	fmt.Println("Exiting main")16}17import (18func main() {19	interrupt_handler := interrupt_handler{}20	interrupt_handler.Start()21	time.Sleep(5 * time.Second)22	interrupt_handler.Stop()23	fmt.Println("Exiting main")24}