- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 246 for acquirem (0.22 sec)
-
src/main/java/jcifs/smb/SmbPipeHandleImpl.java
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Mon Apr 13 17:05:22 UTC 2020 - 10.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/SmoothRateLimiter.java
* evaluate the integral of the function from 7.0 to 10.0. * * Using integrals guarantees that the effect of a single acquire(3) is equivalent to { * acquire(1); acquire(1); acquire(1); }, or { acquire(2); acquire(1); }, etc, since the integral * of the function in [7.0, 10.0] is equivalent to the sum of the integrals of [7.0, 8.0], [8.0,
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 19.3K bytes - Viewed (0) -
src/runtime/metrics.go
// sysStatsAggregate represents system memory stats obtained // from the runtime. This set of stats is grouped together because // they're all relatively cheap to acquire and generally independent // of one another and other runtime memory stats. The fact that they // may be acquired at different times, especially with respect to // heapStatsAggregate, means there could be some skew, but because of
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 08 21:03:13 UTC 2024 - 26K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/SmoothRateLimiter.java
* evaluate the integral of the function from 7.0 to 10.0. * * Using integrals guarantees that the effect of a single acquire(3) is equivalent to { * acquire(1); acquire(1); acquire(1); }, or { acquire(2); acquire(1); }, etc, since the integral * of the function in [7.0, 10.0] is equivalent to the sum of the integrals of [7.0, 8.0], [8.0,
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 19.3K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/work/DefaultWorkerLeaseServiceProjectLockTest.groovy
assert !lockIsHeld(projectLock) } assert lockIsHeld(taskLease) assert lockIsHeld(projectLock) } } def "can acquire task execution lease while holding the project lock"() { def workerLeaseService = workerLeaseService(false) def taskLease = workerLeaseService.getTaskExecutionLock(path("build"), path("project"))
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 25.6K bytes - Viewed (0) -
pkg/kube/krt/collection.go
log *istiolog.Scope // recomputeMu blocks a recomputation of I->O. recomputeMu sync.Mutex // mu protects all items grouped below. // This is acquired for reads and writes of data. // This can be acquired with recomputeMu held, but only with strict ordering (mu inside recomputeMu) mu sync.Mutex collectionState multiIndex[I, O]
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 10 23:33:56 UTC 2024 - 19.4K bytes - Viewed (0) -
src/runtime/HACKING.md
without an active P. In this case, `go:nowritebarrierrec` is used on functions that release the P or may run without a P and `go:yeswritebarrierrec` is used when code re-acquires an active P. Since these are function-level annotations, code that releases or acquires a P may need to be split across two functions. go:uintptrkeepalive ------------------- The //go:uintptrkeepalive directive must be followed by a function declaration.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 13.9K bytes - Viewed (0) -
internal/dsync/dsync_test.go
stopLockServers() os.Exit(code) } func TestSimpleLock(t *testing.T) { dm := NewDRWMutex(ds, "test") dm.Lock(id, source) // fmt.Println("Lock acquired, waiting...") time.Sleep(testDrwMutexRefreshCallTimeout) dm.Unlock(context.Background()) } func TestSimpleLockUnlockMultipleTimes(t *testing.T) { dm := NewDRWMutex(ds, "test") dm.Lock(id, source)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Dec 24 03:49:07 UTC 2022 - 11K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
* <p>To avoid races between threads doing release and acquire, we transition to the final state * in two steps. One thread will successfully CAS from RUNNING to COMPLETING, that thread will * then set the result of the computation, and only then transition to COMPLETED, CANCELLED, or * INTERRUPTED. * * <p>We don't use the integer argument passed between acquire methods so we pass around a -1 * everywhere. */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Apr 06 12:56:11 UTC 2023 - 13.6K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbFileOutputStream.java
protected synchronized SmbFileHandleImpl ensureOpen () throws CIFSException { if ( !isOpen() ) { // one extra acquire to keep this open till the stream is released this.handle = this.file.openUnshared(this.openFlags, this.access, this.sharing, SmbConstants.ATTR_NORMAL, 0).acquire(); if ( this.append ) { this.fp = this.handle.getInitialSize(); if ( log.isDebugEnabled() ) {
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Sat Nov 13 15:14:04 UTC 2021 - 11.9K bytes - Viewed (0)