- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 30 for semrelease1 (0.37 sec)
-
src/runtime/sema_test.go
atomic.CompareAndSwapUint32(&res, 0, 1) Semrelease1(&sema, true, 0) close(done) }() for SemNwait(&sema) == 0 { Gosched() // wait for goroutine to block in Semacquire } // The crux of the test: we release the semaphore with handoff // and immediately perform a CAS both here and in the waiter; we // want the CAS in the waiter to execute first. Semrelease1(&sema, true, 0) atomic.CompareAndSwapUint32(&res, 0, 2)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 21 19:37:22 UTC 2022 - 4.2K bytes - Viewed (0) -
src/runtime/sema.go
break } } if s.releasetime > 0 { blockevent(s.releasetime-t0, 3+skipframes) } releaseSudog(s) } func semrelease(addr *uint32) { semrelease1(addr, false, 0) } func semrelease1(addr *uint32, handoff bool, skipframes int) { root := semtable.rootFor(addr) atomic.Xadd(addr, 1) // Easy case: no waiters?
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 19K bytes - Viewed (0) -
src/runtime/metrics_test.go
return false } runtime.Semacquire(&sem) runtime.Semrelease1(&sem, false, 0) if runtime.MutexContended(runtime.SemRootLock(&sem)) { sawContention.Add(1) } return true } stks := [][]string{ { "runtime.unlock", "runtime.semrelease1", "runtime_test.TestRuntimeLockMetricsAndProfile.func6.1",
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:52:17 UTC 2024 - 45K bytes - Viewed (0) -
src/runtime/export_test.go
var MutexContended = mutexContended func SemRootLock(addr *uint32) *mutex { root := semtable.rootFor(addr) return &root.lock } var Semacquire = semacquire var Semrelease1 = semrelease1 func SemNwait(addr *uint32) uint32 { root := semtable.rootFor(addr) return root.nwait.Load() } const SemTableSize = semTabSize
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:50:53 UTC 2024 - 46.1K bytes - Viewed (0) -
src/runtime/trace.go
// other calls to traceAdvance. semrelease1(&traceAdvanceSema, true, 0) if stopTrace { // Stop the traceAdvancer. We can't be holding traceAdvanceSema here because // we'll deadlock (we're blocked on the advancer goroutine exiting, but it // may be currently trying to acquire traceAdvanceSema). traceAdvancer.stop() semrelease(&traceShutdownSema) } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 21:17:41 UTC 2024 - 37.1K bytes - Viewed (0) -
src/runtime/proc.go
// worldsema must be held over startTheWorldWithSema to ensure // gomaxprocs cannot change while worldsema is held. // // Release worldsema with direct handoff to the next waiter, but // acquirem so that semrelease1 doesn't try to yield our time. // // Otherwise if e.g. ReadMemStats is being called in a loop, // it might stomp on other attempts to stop the world, such as
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 207.5K bytes - Viewed (0) -
src/sync/runtime.go
func runtime_SemacquireMutex(s *uint32, lifo bool, skipframes int) func runtime_SemacquireRWMutexR(s *uint32, lifo bool, skipframes int) func runtime_SemacquireRWMutex(s *uint32, lifo bool, skipframes int) // Semrelease atomically increments *s and notifies a waiting goroutine // if one is blocked in Semacquire. // It is intended as a simple wakeup primitive for use by the synchronization // library and should not be used directly.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 16 16:32:27 UTC 2022 - 2.3K bytes - Viewed (0) -
maven-resolver-provider/src/main/java/org/apache/maven/repository/internal/VersionsMetadata.java
Versioning versioning = new Versioning(); versioning.addVersion(artifact.getBaseVersion()); if (!artifact.isSnapshot()) { versioning.setRelease(artifact.getBaseVersion()); } if ("maven-plugin".equals(artifact.getProperty(ArtifactProperties.TYPE, ""))) { versioning.setLatest(artifact.getBaseVersion()); }
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Thu Apr 25 10:10:21 UTC 2024 - 4.2K bytes - Viewed (0) -
maven-compat/src/main/java/org/apache/maven/project/artifact/ActiveProjectArtifact.java
} /** {@inheritDoc} */ public boolean isRelease() { return artifact.isRelease(); } /** {@inheritDoc} */ public void setRelease(boolean release) { artifact.setRelease(release); } /** {@inheritDoc} */ public List<ArtifactVersion> getAvailableVersions() { return artifact.getAvailableVersions(); }
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Sep 06 08:39:32 UTC 2023 - 9.2K bytes - Viewed (0) -
platforms/jvm/language-jvm/src/main/java/org/gradle/api/internal/tasks/compile/JvmLanguageCompileSpec.java
void setSourceFiles(Iterable<File> sourceFiles); List<File> getCompileClasspath(); void setCompileClasspath(List<File> classpath); @Nullable Integer getRelease(); void setRelease(@Nullable Integer release); @Nullable String getSourceCompatibility(); void setSourceCompatibility(@Nullable String sourceCompatibility); @Nullable String getTargetCompatibility();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Aug 28 11:40:18 UTC 2023 - 1.6K bytes - Viewed (0)