- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 502 for Instant (0.29 sec)
-
platforms/core-runtime/concurrent/src/test/groovy/org/gradle/internal/concurrent/DefaultExecutorFactoryTest.groovy
instant.willStop executor.stop() instant.stopped } then: instant.stopped > instant.completed1 instant.stopped > instant.completed2 } def factoryStopBlocksUntilAllScheduledRunningJobsAreCompleted() { given: def action1 = { instant.started1 thread.blockUntil.willStop thread.block()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 19:07:35 UTC 2024 - 11.2K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/work/DefaultWorkerLeaseServiceProjectLockTest.groovy
workerLeaseService.withLocks([taskLease]) { instant.worker1Locked thread.block() instant.worker1Unlocked } } start { thread.blockUntil.worker1Locked workerLeaseService.withLocks([taskLease]) { instant.worker2Locked assert lockIsHeld(taskLease)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 25.6K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/api/internal/project/DefaultProjectStateRegistryTest.groovy
state.applyToMutableState { assert state.hasMutableState() instant.thread2 } assert !state.hasMutableState() } } then: instant.thread2 > instant.thread1 } def "a given thread can only access the state of one project at a time"() { given:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 24.6K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/event/DefaultListenerManagerTest.groovy
} then: instant.bReceived > instant.aHandled } def notifyDoesNotBlockWhenAnotherThreadIsNotifyingOnDifferentType() { given: def listener1 = { String p -> instant.aReceived thread.block() instant.aHandled } as TestFooListener def listener2 = { instant.bReceived } as TestBarListener
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 02:21:10 UTC 2024 - 29.1K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/server/DaemonStateCoordinatorTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sun May 05 22:24:02 UTC 2024 - 16.3K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/LockOnDemandCrossProcessCacheAccessTest.groovy
when: async { start { cacheAccess.withFileLock { instant.action1 thread.blockUntil.action2 } } start { cacheAccess.withFileLock { instant.action2 thread.blockUntil.action1 } } } then:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:51 UTC 2024 - 21.8K bytes - Viewed (0) -
platforms/core-runtime/build-operations/src/test/groovy/org/gradle/internal/operations/DefaultBuildOperationRunnerTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Mar 08 15:56:07 UTC 2024 - 29.3K bytes - Viewed (0) -
testing/internal-integ-testing/src/test/groovy/org/gradle/test/fixtures/server/http/BlockingHttpServerTest.groovy
request2.release() } server.stop() then: instant.aDone > instant.aBlocked instant.bDone > instant.bBlocked } def "can chain expectations"() { given: server.expectConcurrent("a", "b") server.expect("c") def handle = server.expectConcurrentAndBlock(2, "d", "e") server.expect("f")
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 46.1K bytes - Viewed (0) -
src/net/dial_test.go
}{ // These should just work on the first try. {[]string{"127.0.0.1"}, []string{}, "", true, instant}, {[]string{"::1"}, []string{}, "", true, instant}, {[]string{"127.0.0.1", "::1"}, []string{slowDst6}, "tcp6", true, instant}, {[]string{"::1", "127.0.0.1"}, []string{slowDst4}, "tcp4", true, instant}, // Primary is slow; fallback should kick in. {[]string{slowDst4}, []string{"::1"}, "", true, fallbackDelay},
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 20 06:04:31 UTC 2024 - 30.3K bytes - Viewed (0) -
src/cmd/trace/gstate.go
// to emit a flow event from, indicating explicitly that this goroutine was unblocked by the system. func (gs *gState[R]) blockedSyscallEnd(ts trace.Time, stack trace.Stack, ctx *traceContext) { name := "exit blocked syscall" gs.setStartCause(ts, name, trace.SyscallP, stack) // Emit an syscall exit instant event for the "Syscall" lane. ctx.Instant(traceviewer.InstantEvent{ Name: name,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 11.9K bytes - Viewed (0)