- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 288 for Parallel (0.17 sec)
-
platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/work/AbstractWorkerLeaseServiceTest.groovy
return workerLeaseService(true, maxWorkers) } WorkerLeaseService workerLeaseService(boolean parallel, int maxWorkers = 1) { def service = new DefaultWorkerLeaseService(coordinationService, new DefaultWorkerLimits(maxWorkers)) service.startProjectExecution(parallel) return service } TestTrackedResourceLock resourceLock(String displayName, boolean locked, boolean hasLock = false) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 1.8K bytes - Viewed (0) -
src/runtime/chanbarrier_test.go
}() } r := <-ch runtime.Gosched() return r.resp, r.err } func TestChanSendSelectBarrier(t *testing.T) { t.Parallel() testChanSendBarrier(true) } func TestChanSendBarrier(t *testing.T) { t.Parallel() testChanSendBarrier(false) } func testChanSendBarrier(useSelect bool) { var wg sync.WaitGroup outer := 100 inner := 100000
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 06 17:50:18 UTC 2024 - 1.4K bytes - Viewed (0) -
src/cmd/cgo/internal/testerrors/errors_test.go
func path(file string) string { return filepath.Join("testdata", file) } func check(t *testing.T, file string) { t.Run(file, func(t *testing.T) { testenv.MustHaveGoBuild(t) testenv.MustHaveCGO(t) t.Parallel() contents, err := os.ReadFile(path(file)) if err != nil { t.Fatal(err) } var errors []*regexp.Regexp for i, line := range bytes.Split(contents, []byte("\n")) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 20 15:50:06 UTC 2024 - 4K bytes - Viewed (0) -
src/cmd/link/internal/ld/deadcode_test.go
// license that can be found in the LICENSE file. package ld import ( "bytes" "internal/testenv" "path/filepath" "testing" ) func TestDeadcode(t *testing.T) { testenv.MustHaveGoBuild(t) t.Parallel() tmpdir := t.TempDir() tests := []struct { src string pos, neg []string // positive and negative patterns }{ {"reflectcall", nil, []string{"main.T.M"}},
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 01 15:07:26 UTC 2023 - 1.7K bytes - Viewed (0) -
src/net/http/main_test.go
} return true } // setParallel marks t as a parallel test if we're in short mode // (all.bash), but as a serial test otherwise. Using t.Parallel isn't // compatible with the afterTest func in non-short mode. func setParallel(t *testing.T) { if strings.Contains(t.Name(), "HTTP2") { http.CondSkipHTTP2(t) } if testing.Short() { t.Parallel() } } func runningBenchmarks() bool {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 03 22:49:46 UTC 2024 - 4.9K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/executer/GradleContextualExecuter.java
forking(true), noDaemon(true), parallel(true, true), configCache(true), isolatedProjects(true); final public boolean forks; final public boolean executeParallel; Executer(boolean forks) { this(forks, false); } Executer(boolean forks, boolean parallel) { this.forks = forks;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 09 18:06:31 UTC 2024 - 7.2K bytes - Viewed (0) -
platforms/ide/tooling-api-builders/src/test/groovy/org/gradle/tooling/internal/provider/runner/IntermediateBuildActionRunnerTest.groovy
def buildModelParameters = Mock(BuildModelParameters) def runner = new IntermediateBuildActionRunner(buildOperationExecutor, buildModelParameters, "Test operation") def "parallelism is defined by Tooling API parallel actions"() { when: runner.isParallel() then: 1 * buildModelParameters.isParallelToolingApiActions() >> true 0 * _ } def "runs supplied actions"() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Nov 20 17:58:18 UTC 2023 - 4.6K bytes - Viewed (0) -
src/os/exec_unix_test.go
//go:build unix package os_test import ( "errors" "internal/testenv" "math" . "os" "runtime" "syscall" "testing" ) func TestErrProcessDone(t *testing.T) { testenv.MustHaveGoBuild(t) t.Parallel() p, err := StartProcess(testenv.GoToolPath(t), []string{"go"}, &ProcAttr{}) if err != nil { t.Fatalf("starting test process: %v", err) } p.Wait() if got := p.Signal(Kill); got != ErrProcessDone {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 18:08:44 UTC 2024 - 2K bytes - Viewed (0) -
platforms/jvm/scala/src/integTest/groovy/org/gradle/scala/ScalaConcurrencyIntegrationTest.groovy
class ScalaConcurrencyIntegrationTest extends AbstractIntegrationSpec { @Rule BlockingHttpServer httpServer = new BlockingHttpServer() @Issue("https://github.com/gradle/gradle/issues/14434") def "can run tests in parallel with project dependencies"() { given: httpServer.expectConcurrent(':a:test', ':b:test', ':c:test', ':d:test') httpServer.start() settingsFile << """ include 'a', 'b', 'c', 'd'
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 16:10:12 UTC 2024 - 3.4K bytes - Viewed (0) -
testing/internal-performance-testing/src/main/groovy/org/gradle/performance/generator/TestProjectGeneratorConfiguration.groovy
CompositeConfiguration compositeBuild String daemonMemory String compilerMemory String testRunnerMemory Map<String, String> systemProperties String[] featurePreviews boolean parallel int maxWorkers int maxParallelForks int testForkEvery boolean useTestNG Map<String, String> fileToChangeByScenario } @Builder(prefix = "with", builderStrategy = ExternalStrategy,
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 18 13:08:21 UTC 2024 - 5.6K bytes - Viewed (0)