- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 5,554 for acquired (0.1 sec)
-
guava/src/com/google/common/util/concurrent/Monitor.java
// places you'll have monitor.enter()/monitor.leave() and other // places you'll have guard.enter()/guard.leave() even though // it's the same lock being acquired underneath. Always using // monitor.enterXXX()/monitor.leave() will make it really clear // which lock is held at any point in the code. //
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Dec 04 18:22:01 UTC 2023 - 42.5K bytes - Viewed (0) -
src/runtime/arena.go
} if asanenabled { asanpoison(unsafe.Pointer(s.base()), s.elemsize) } // Make ourselves non-preemptible as we manipulate state and statistics. // // Also required by setUserArenaChunksToFault. mp := acquirem() // We can only set user arenas to fault if we're in the _GCoff phase. if gcphase == _GCoff { lock(&userArenaState.lock) faultList := userArenaState.fault
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 17:44:56 UTC 2024 - 37.9K bytes - Viewed (0) -
src/internal/trace/internal/oldtrace/parser.go
return Events{}, ErrTimeOrder } // The last part is giving correct timestamps to EvGoSysExit events. The // problem with EvGoSysExit is that actual syscall exit timestamp // (ev.Args[2]) is potentially acquired long before event emission. So far // we've used timestamp of event emission (ev.Ts). We could not set ev.Ts = // ev.Args[2] earlier, because it would produce seemingly broken timestamps
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 24 21:15:28 UTC 2024 - 46.8K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTreeImpl.java
*/ public SmbTreeImpl acquire ( boolean track ) { long usage = this.usageCount.incrementAndGet(); if ( log.isTraceEnabled() ) { log.trace("Acquire tree " + usage + " " + this); } if ( track && this.traceResource ) { synchronized ( this.acquires ) { this.acquires.add(truncateTrace(Thread.currentThread().getStackTrace()));
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Thu Jan 05 13:06:39 UTC 2023 - 29.6K bytes - Viewed (0) -
src/runtime/mcache.go
// flushGen indicates the sweepgen during which this mcache // was last flushed. If flushGen != mheap_.sweepgen, the spans // in this mcache are stale and need to the flushed so they // can be swept. This is done in acquirep. flushGen atomic.Uint32 } // A gclink is a node in a linked list of blocks, like mlink, // but it is opaque to the garbage collector. // The GC does not trace the pointers during collection,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 10K bytes - Viewed (0) -
src/runtime/mstats.go
noPLock mutex } // acquire returns a heapStatsDelta to be updated. In effect, // it acquires the shard for writing. release must be called // as soon as the relevant deltas are updated. // // The returned heapStatsDelta must be updated atomically. // // The caller's P must not change between acquire and // release. This also means that the caller should not // acquire a P or release its P in between. A P also must
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 08 21:03:13 UTC 2024 - 34.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java
limiter.acquire(Integer.MAX_VALUE / 4); limiter.acquire(Integer.MAX_VALUE / 2); limiter.acquire(Integer.MAX_VALUE); assertEvents("R0.00", "R0.00", "R0.00"); // no wait, infinite rate! limiter.setRate(2.0); limiter.acquire(); limiter.acquire(); limiter.acquire(); limiter.acquire(); limiter.acquire(); assertEvents(
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 21.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java
limiter.acquire(Integer.MAX_VALUE / 4); limiter.acquire(Integer.MAX_VALUE / 2); limiter.acquire(Integer.MAX_VALUE); assertEvents("R0.00", "R0.00", "R0.00"); // no wait, infinite rate! limiter.setRate(2.0); limiter.acquire(); limiter.acquire(); limiter.acquire(); limiter.acquire(); limiter.acquire(); assertEvents(
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 21.6K bytes - Viewed (0) -
src/runtime/mgclimit.go
func (l *gcCPULimiterState) startGCTransition(enableGC bool, now int64) { if !l.tryLock() { // This must happen during a STW, so we can't fail to acquire the lock. // If we did, something went wrong. Throw. throw("failed to acquire lock to start a GC transition") } if l.gcEnabled == enableGC { throw("transitioning GC to the same state as before?") }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 22 22:07:41 UTC 2024 - 17.3K 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)