- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 1,023 for Parallel (0.13 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/go/internal/modfetch/codehost/git_test.go
} return NewRepo(ctx, vcsName, remote) } func TestTags(t *testing.T) { t.Parallel() type tagsTest struct { repo string prefix string tags []Tag } runTest := func(tt tagsTest) func(*testing.T) { return func(t *testing.T) { t.Parallel() ctx := testContext(t) r, err := testRepo(ctx, t, tt.repo) if err != nil { t.Fatal(err)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Dec 14 19:46:23 UTC 2023 - 18.9K bytes - Viewed (0) -
android/guava/src/com/google/common/graph/MultiEdgesConnecting.java
/** * A class to represent the set of edges connecting an (implicit) origin node to a target node. * * <p>The {@link #outEdgeToNode} map allows this class to work on networks with parallel edges. See * {@link EdgesConnecting} for a class that is more efficient but forbids parallel edges. * * @author James Sexton * @param <E> Edge parameter type */ @ElementTypesAreNonnullByDefault abstract class MultiEdgesConnecting<E> extends AbstractSet<E> {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Oct 06 00:47:57 UTC 2021 - 2.2K bytes - Viewed (0) -
src/cmd/go/testdata/script/test2json_interrupt.txt
[short] skip 'links and runs a test binary' [!fuzz] skip 'tests SIGINT behavior for interrupting fuzz tests' [GOOS:windows] skip 'windows does not support os.Interrupt' ? go test -json -fuzz FuzzInterrupt -run '^$' -parallel 1 stdout -count=1 '"Action":"pass","Package":"example","Test":"FuzzInterrupt"' stdout -count=1 '"Action":"pass","Package":"example","Elapsed":' mkdir $WORK/fuzzcache go test -c . -fuzz=. -o example_test.exe
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Dec 08 03:52:44 UTC 2022 - 1.7K 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/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) -
platforms/core-execution/workers/src/integTest/groovy/org/gradle/workers/internal/WorkerExecutorParallelIntegrationTest.groovy
} parallelWorkAction.writeToBuildFile() alternateParallelWorkAction.writeToBuildFile() withMultipleActionTaskTypeInBuildScript() } def "multiple work items can be executed in parallel in #isolationMode (wait for results: #waitForResults)"() { given: buildFile << """ task parallelWorkTask(type: MultipleWorkItemTask) { isolationMode = '$isolationMode'
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 24 06:54:47 UTC 2023 - 31.7K bytes - Viewed (0) -
src/go/doc/testdata/testing.go
func (c *common) Fatalf(format string, args ...any) { c.log(fmt.Sprintf(format, args...)) c.FailNow() } // Parallel signals that this test is to be run in parallel with (and only with) // other parallel tests in this CPU group. func (t *T) Parallel() { t.signal <- (*T)(nil) // Release main testing loop <-t.startParallel // Wait for serial tests to finish }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sun Oct 02 02:28:27 UTC 2022 - 11.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/grpc_service_unix_test.go
// Since the Dial to kms-plugin is non-blocking we expect the construction of gRPC service to succeed even when // kms-plugin is not yet up - dialing happens in the background. func TestKMSPluginLateStart(t *testing.T) { t.Parallel() callTimeout := 3 * time.Second s := newEndpoint() ctx := testContext(t) service, err := NewGRPCService(ctx, s.endpoint, callTimeout) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 29 05:36:41 UTC 2023 - 10K bytes - Viewed (0)