How to use isRunningInParallel method of internal Package

...186	}187	suite.currentSpecReport.ReportEntries = append(suite.currentSpecReport.ReportEntries, entry)188	return nil189}190func (suite *Suite) isRunningInParallel() bool {191	return suite.config.ParallelTotal > 1192}193func (suite *Suite) processCurrentSpecReport() {194	suite.reporter.DidRun(suite.currentSpecReport)195	if suite.isRunningInParallel() {196		suite.client.PostDidRun(suite.currentSpecReport)197	}198	suite.report.SpecReports = append(suite.report.SpecReports, suite.currentSpecReport)199	if suite.currentSpecReport.State.Is(types.SpecStateFailureStates) {200		suite.report.SuiteSucceeded = false201		if suite.config.FailFast || suite.currentSpecReport.State.Is(types.SpecStateAborted) {202			suite.skipAll = true203			if suite.isRunningInParallel() {204				suite.client.PostAbort()205			}206		}207	}208}209func (suite *Suite) runSpecs(description string, suiteLabels Labels, suitePath string, hasProgrammaticFocus bool, specs Specs) bool {210	numSpecsThatWillBeRun := specs.CountWithoutSkip()211	suite.report = types.Report{212		SuitePath:                 suitePath,213		SuiteDescription:          description,214		SuiteLabels:               suiteLabels,215		SuiteConfig:               suite.config,216		SuiteHasProgrammaticFocus: hasProgrammaticFocus,217		PreRunStats: types.PreRunStats{218			TotalSpecs:       len(specs),219			SpecsThatWillRun: numSpecsThatWillBeRun,220		},221		StartTime: time.Now(),222	}223	suite.reporter.SuiteWillBegin(suite.report)224	if suite.isRunningInParallel() {225		suite.client.PostSuiteWillBegin(suite.report)226	}227	suite.report.SuiteSucceeded = true228	suite.runBeforeSuite(numSpecsThatWillBeRun)229	if suite.report.SuiteSucceeded {230		groupedSpecIndices, serialGroupedSpecIndices := OrderSpecs(specs, suite.config)231		nextIndex := MakeIncrementingIndexCounter()232		if suite.isRunningInParallel() {233			nextIndex = suite.client.FetchNextCounter234		}235		for {236			groupedSpecIdx, err := nextIndex()237			if err != nil {238				suite.report.SpecialSuiteFailureReasons = append(suite.report.SpecialSuiteFailureReasons, fmt.Sprintf("Failed to iterate over specs:\n%s", err.Error()))239				suite.report.SuiteSucceeded = false240				break241			}242			if groupedSpecIdx >= len(groupedSpecIndices) {243				if suite.config.ParallelProcess == 1 && len(serialGroupedSpecIndices) > 0 {244					groupedSpecIndices, serialGroupedSpecIndices, nextIndex = serialGroupedSpecIndices, GroupedSpecIndices{}, MakeIncrementingIndexCounter()245					suite.client.BlockUntilNonprimaryProcsHaveFinished()246					continue247				}248				break249			}250			// the complexity for running groups of specs is very high because of Ordered containers and FlakeAttempts251			// we encapsulate that complexity in the notion of a Group that can run252			// Group is really just an extension of suite so it gets passed a suite and has access to all its internals253			// Note that group is stateful and intedned for single use!254			newGroup(suite).run(specs.AtIndices(groupedSpecIndices[groupedSpecIdx]))255		}256		if specs.HasAnySpecsMarkedPending() && suite.config.FailOnPending {257			suite.report.SpecialSuiteFailureReasons = append(suite.report.SpecialSuiteFailureReasons, "Detected pending specs and --fail-on-pending is set")258			suite.report.SuiteSucceeded = false259		}260	}261	suite.runAfterSuiteCleanup(numSpecsThatWillBeRun)262	interruptStatus := suite.interruptHandler.Status()263	if interruptStatus.Interrupted {264		suite.report.SpecialSuiteFailureReasons = append(suite.report.SpecialSuiteFailureReasons, interruptStatus.Cause.String())265		suite.report.SuiteSucceeded = false266	}267	suite.report.EndTime = time.Now()268	suite.report.RunTime = suite.report.EndTime.Sub(suite.report.StartTime)269	if suite.config.ParallelProcess == 1 {270		suite.runReportAfterSuite()271	}272	suite.reporter.SuiteDidEnd(suite.report)273	if suite.isRunningInParallel() {274		suite.client.PostSuiteDidEnd(suite.report)275	}276	return suite.report.SuiteSucceeded277}278func (suite *Suite) runBeforeSuite(numSpecsThatWillBeRun int) {279	interruptStatus := suite.interruptHandler.Status()280	beforeSuiteNode := suite.suiteNodes.FirstNodeWithType(types.NodeTypeBeforeSuite | types.NodeTypeSynchronizedBeforeSuite)281	if !beforeSuiteNode.IsZero() && !interruptStatus.Interrupted && numSpecsThatWillBeRun > 0 {282		suite.currentSpecReport = types.SpecReport{283			LeafNodeType:     beforeSuiteNode.NodeType,284			LeafNodeLocation: beforeSuiteNode.CodeLocation,285			ParallelProcess:  suite.config.ParallelProcess,286		}287		suite.reporter.WillRun(suite.currentSpecReport)...

1import (2func main() {3    fmt.Println(runtime.NumCPU())4    fmt.Println(runtime.NumGoroutine())5    fmt.Println(runtime.GOMAXPROCS(0))6    fmt.Println(runtime.GOMAXPROCS(1))7    fmt.Println(runtime.GOMAXPROCS(2))8    fmt.Println(runtime.GOMAXPROCS(3))9    fmt.Println(runtime.GOMAXPROCS(4))10    fmt.Println(runtime.GOMAXPROCS(5))11    fmt.Println(runtime.GOMAXPROCS(6))12    fmt.Println(runtime.GOMAXPROCS(7))13    fmt.Println(runtime.GOMAXPROCS(8))14    fmt.Println(runtime.GOMAXPROCS(9))15    fmt.Println(runtime.GOMAXPROCS(10))16    fmt.Println(runtime.GOMAXPROCS(11))17    fmt.Println(runtime.GOMAXPROCS(12))18    fmt.Println(runtime.GOMAXPROCS(13))19    fmt.Println(runtime.GOMAXPROCS(14))20    fmt.Println(runtime.GOMAXPROCS(15))21    fmt.Println(runtime.GOMAXPROCS(16))22    fmt.Println(runtime.GOMAXPROCS(17))23    fmt.Println(runtime.GOMAXPROCS(18))24    fmt.Println(runtime.GOMAXPROCS(19))25    fmt.Println(runtime.GOMAXPROCS(20))26    fmt.Println(runtime.GOMAXPROCS(21))27    fmt.Println(runtime.GOMAXPROCS(22))28    fmt.Println(runtime.GOMAXPROCS(23))29    fmt.Println(runtime.GOMAXPROCS(24))30    fmt.Println(runtime.GOMAXPROCS(25))31    fmt.Println(runtime.GOMAXPROCS(26))32    fmt.Println(runtime.GOMAXPROCS(27))33    fmt.Println(runtime.GOMAXPROCS(28))34    fmt.Println(runtime.GOMAXPROCS(29))35    fmt.Println(runtime.GOMAXPROCS(30))36    fmt.Println(runtime.GOMAXPROCS(31))37    fmt.Println(runtime.GOMAXPROCS(32))38}39import (40func main() {41    fmt.Println(runtime.NumCPU())42    fmt.Println(runtime.NumGoroutine())43    fmt.Println(runtime.GOMAXPROCS(0))

1import (2func main() {3    fmt.Println(runtime.NumCPU())4    fmt.Println(runtime.GOMAXPROCS(0))5    fmt.Println(runtime.NumGoroutine())6    fmt.Println(runtime.Gosched())7    fmt.Println(runtime.Goexit())8    fmt.Println(runtime.LockOSThread())9    fmt.Println(runtime.UnlockOSThread())10    fmt.Println(runtime.Goexit())11    fmt.Println(runtime.Gosched())12    fmt.Println(runtime.GOMAXPROCS(0))13    fmt.Println(runtime.NumGoroutine())14    fmt.Println(runtime.NumCPU())15    wg.Add(1)16    go func() {17        defer wg.Done()18        fmt.Println("We are in parallel")19    }()20    wg.Wait()21    fmt.Println("We are not in parallel")22}

1import (2func main() {3	wg.Add(3)4	go func() {5		defer wg.Done()6		fmt.Println("Goroutine 1")7	}()8	go func() {9		defer wg.Done()10		fmt.Println("Goroutine 2")11	}()12	go func() {13		defer wg.Done()14		fmt.Println("Goroutine 3")15	}()16	wg.Wait()17	fmt.Println("main function")18}

1import (2func main() {3	fmt.Println("Number of CPUs:", runtime.NumCPU())4	fmt.Println("Number of Go Routines:", runtime.NumGoroutine())5	fmt.Println("Is Running in Parallel:", atomic.IsRunningInParallel())6}

1import (2func main() {3	fmt.Println(runtime.IsRunningInParallel())4	time.Sleep(5 * time.Second)5}6import (7func main() {8	fmt.Println(runtime.IsRunningInParallel())9}

1import (2func main() {3    fmt.Println(parallelism.IsRunningInParallel())4}5import (6func main() {7    fmt.Println(parallelism.IsRunningInParallel())8}9import (10func main() {11    fmt.Println(parallelism.IsRunningInParallel())12}13import (14func main() {15    fmt.Println(parallelism.IsRunningInParallel())16}17import (18func main() {19    fmt.Println(parallelism.IsRunningInParallel())20}21import (22func main() {23    fmt.Println(parallelism.IsRunningInParallel())24}25import (26func main() {27    fmt.Println(parallelism.IsRunningInParallel())28}29import (30func main() {31    fmt.Println(parallelism.IsRunningInParallel())32}33import (