How to use PostAbort method of parallel_support Package

...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})...

...37	BlockUntilSynchronizedBeforeSuiteData() (types.SpecState, []byte, error)38	BlockUntilNonprimaryProcsHaveFinished() error39	BlockUntilAggregatedNonprimaryProcsReport() (types.Report, error)40	FetchNextCounter() (int, error)41	PostAbort() error42	ShouldAbort() bool43	Write(p []byte) (int, error)44}45func NewServer(parallelTotal int, reporter reporters.Reporter) (Server, error) {46	if os.Getenv("GINKGO_PARALLEL_PROTOCOL") == "HTTP" {47		return newHttpServer(parallelTotal, reporter)48	} else {49		return newRPCServer(parallelTotal, reporter)50	}51}52func NewClient(serverHost string) Client {53	if os.Getenv("GINKGO_PARALLEL_PROTOCOL") == "HTTP" {54		return newHttpClient(serverHost)55	} else {...

1import (2func main() {3    p.PostAbort()4}5import (6func main() {7    p.PostAbort()8}9import (10func main() {11    p.PostAbort()12}13import (14func main() {15    p.PostAbort()16}17import (18func main() {19    p.PostAbort()20}21import (22func main() {23    p.PostAbort()24}25import (26func main() {27    p.PostAbort()28}29import (30func main() {31    p.PostAbort()32}33import (34func main() {35    p.PostAbort()36}37import (38func main() {

1import (2func main() {3    wg.Add(1)4    ps.Init()5    go func() {6        ps.PostAbort()7        wg.Done()8    }()9    err := ps.Run(func() error {10        for {11            time.Sleep(1 * time.Second)12        }13    })14    if err != nil {15        fmt.Println("Error: ", err)16    }17    wg.Wait()18}19import (20func main() {21    wg.Add(1)22    ps.Init()23    go func() {24        ps.PostAbort()25        wg.Done()26    }()27    err := ps.Run(func() error {28        for {29            time.Sleep(1 * time.Second)30        }31    })32    if err != nil {33        fmt.Println("Error: ", err)34    }35    wg.Wait()36}37import (38func main() {39    wg.Add(1)40    ps.Init()41    go func() {42        ps.PostAbort()43        wg.Done()44    }()45    err := ps.Run(func() error {46        for {47            time.Sleep(1 * time.Second)48        }49    })50    if err != nil {51        fmt.Println("Error: ", err)52    }53    wg.Wait()54}55import (56func main() {57    wg.Add(1)58    ps.Init()59    go func() {60        ps.PostAbort()61        wg.Done()62    }()63    err := ps.Run(func() error {64        for {65            time.Sleep(1

1import (2func main() {3    runtime.GOMAXPROCS(2)4    p.Init()5    go p.PostAbort()6    fmt.Println("Hello, playground")7}8import (9func main() {10    runtime.GOMAXPROCS(2)11    p.Init()12    go p.PostAbort()13    fmt.Println("Hello, playground")14}

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

1import (2func main() {3    ps := parallel_support.NewParallelSupport()4    ps.Start()5    ps.AddTask(func() {6        fmt.Println("Task 1")7        ps.Sleep(5)8    })9    ps.AddTask(func() {10        fmt.Println("Task 2")11        ps.Sleep(3)12    })13    ps.Wait()14    ps.PostAbort()

1import (2func main() {3	p := parallel_support.NewParallelSupport()4	f := []func() error{5		func() error {6			fmt.Println("Function 1")7		},8		func() error {9			fmt.Println("Function 2")10		},11		func() error {12			fmt.Println("Function 3")13		},14	}15	p.Parallel(f)16	p.PostAbort()17	p.Wait()18}19import (20func main() {21	p := parallel_support.NewParallelSupport()22	f := []func() error{23		func() error {24			fmt.Println("Function 1")25			time.Sleep(5 * time.Second)26		},27		func() error {28			fmt.Println("Function 2")29		},30		func() error {31			fmt.Println("Function 3")32		},33	}34	p.Parallel(f)35	p.PostAbort()36	p.Wait()37}38import (39func main() {40	p := parallel_support.NewParallelSupport()41	f := []func() error{42		func() error {43			fmt.Println("Function 1")44			time.Sleep(5 * time.Second)45		},46		func() error {47			fmt.Println("Function 2")48		},49		func() error {50			fmt.Println("Function 3")51		},52	}53	p.Parallel(f)

1import (2func main() {3	parallelObj := parallel_support.NewParallelSupport()4	parallelObj.AddFunctionToExecute(Add, 1, 2)5	parallelObj.AddFunctionToExecute(Multiply, 1, 2)6	parallelObj.AddFunctionToExecute(Subtract, 1, 2)7	parallelObj.StartExecution()8	parallelObj.Wait()9	if parallelObj.IsAborted() {10		fmt.Println("Aborted")11	}12}13func Add(a, b int) int {14}15func Multiply(a, b int) int {16}17func Subtract(a, b int) int {18}19import (20func main() {21	parallelObj := parallel_support.NewParallelSupport()22	parallelObj.AddFunctionToExecute(Add, 1, 2)23	parallelObj.AddFunctionToExecute(Multiply, 1, 2)24	parallelObj.AddFunctionToExecute(Subtract, 1, 2)25	parallelObj.StartExecution()26	parallelObj.Wait()27	if parallelObj.IsAborted() {28		fmt.Println("Aborted")29	}30}31func Add(a, b int) int {32}33func Multiply(a, b int)

1import (2func main() {3	var task *parallel_support.ParallelTask = parallel_support.StartParallelTask(func() {4		for i := 1; i <= 1000; i++ {5		}6	})7	fmt.Println("Enter a number to abort the parallel task")8	fmt.Scanln(&input)9	if len(strings.TrimSpace(input)) > 0 {10		task.PostAbort()11	}12	fmt.Println("Sum of first 1000 integers = ", sum)13}14import (15func main() {