- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 44 for Synchronizer (0.34 sec)
-
tensorflow/compiler/jit/xla_host_recv_device_context.cc
if (!status.ok()) { done(status); return; } if (auto st = stream_->BlockHostUntilDone(); !st.ok()) { done_event_.SetError(absl::InternalError(absl::StrFormat( "failed to synchronize send operation with a stream: %s", st.ToString()))); return; } done_event_.SetStateConcrete(); done(absl::OkStatus()); }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri May 17 22:46:36 UTC 2024 - 1.9K bytes - Viewed (0) -
internal/logger/logrotate.go
type Writer struct { // opts are the configuration options for this Writer opts Options // f is the currently open file used for appends. // Writes to f are only synchronized once Close() is called, // or when files are being rotated. f *os.File pw *xioutil.PipeWriter pr *xioutil.PipeReader } // Write writes p into the current file, rotating if necessary.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.8K bytes - Viewed (0) -
platforms/core-runtime/build-process-services/src/main/java/org/gradle/internal/installation/CurrentGradleInstallationLocator.java
private static final String BEACON_CLASS_NAME = "org.gradle.internal.installation.beacon.InstallationBeacon"; private CurrentGradleInstallationLocator() { } public synchronized static CurrentGradleInstallation locate() { return locateViaClassLoader(CurrentGradleInstallationLocator.class.getClassLoader()); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri May 24 06:16:07 UTC 2024 - 3.2K bytes - Viewed (0) -
platforms/core-execution/worker-main/src/main/java/org/gradle/process/internal/worker/child/BootstrapSecurityManager.java
this(null); } BootstrapSecurityManager(URLClassLoader target) { this.target = target; } @Override public void checkPermission(Permission permission) { synchronized (this) { if (initialised) { return; } if (System.in == null) { // Still starting up return; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 23 05:58:56 UTC 2024 - 3.5K bytes - Viewed (0) -
platforms/core-runtime/logging/src/main/java/org/gradle/internal/logging/console/ThrottlingOutputEventListener.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 13:09:37 UTC 2024 - 3.9K bytes - Viewed (0) -
src/sync/once.go
import ( "sync/atomic" ) // Once is an object that will perform exactly one action. // // A Once must not be copied after first use. // // In the terminology of [the Go memory model], // the return from f “synchronizes before” // the return from any call of once.Do(f). // // [the Go memory model]: https://go.dev/ref/mem type Once struct { // done indicates whether the action has been performed.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 2.5K bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/cache/internal/DefaultGeneratedGradleJarCacheIntegrationTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 5K bytes - Viewed (0) -
src/sync/mutex.go
// // In the terminology of [the Go memory model], // the n'th call to [Mutex.Unlock] “synchronizes before” the m'th call to [Mutex.Lock] // for any n < m. // A successful call to [Mutex.TryLock] is equivalent to a call to Lock. // A failed call to TryLock does not establish any “synchronizes before” // relation at all. // // [the Go memory model]: https://go.dev/ref/mem type Mutex struct { state int32
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 8.4K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/service/scopes/SettingsScopeServices.java
CacheConfigurationsInternal cacheConfigurations = objectFactory.newInstance(DefaultCacheConfigurations.class, legacyCacheCleanupEnablement); if (gradleInternal.isRootBuild()) { cacheConfigurations.synchronize(persistentCacheConfigurations); persistentCacheConfigurations.setCleanupHasBeenConfigured(false); } return cacheConfigurations; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 27 09:21:42 UTC 2024 - 5.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/base/FinalizableReferenceQueueTest.java
} static class DecoupledClassLoader extends URLClassLoader { public DecoupledClassLoader(URL[] urls) { super(urls); } @Override protected synchronized Class<?> loadClass(String name, boolean resolve) throws ClassNotFoundException { // Force Finalizer to load from this class loader, not its parent. if (name.equals(Finalizer.class.getName())) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 10 19:21:11 UTC 2024 - 4.8K bytes - Viewed (0)