- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 139 for Synchronizer (0.18 sec)
-
guava-tests/test/com/google/common/collect/ImmutableSortedMultisetTest.java
toArrayCalled = true; return super.toArray(a); } } // Test that toArray() is used to make a defensive copy in copyOf(), so concurrently modified // synchronized collections can be safely copied. TestArrayList<String> toCopy = new TestArrayList<>(); ImmutableSortedMultiset<String> unused = ImmutableSortedMultiset.copyOf(Ordering.natural(), toCopy);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri May 17 15:27:58 UTC 2024 - 22.5K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/resolveengine/result/StreamingResolutionResultBuilder.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 23 17:30:13 UTC 2024 - 11.4K bytes - Viewed (0) -
pkg/kubelet/cm/dra/plugin/noderesources.go
maxRetryPeriod = 180 * time.Second backoffFactor = 2.0 // Introduce a backoff multiplier as jitter factor ) // nodeResourcesController collects resource information from all registered // plugins and synchronizes that information with ResourceSlice objects. type nodeResourcesController struct { ctx context.Context kubeClient kubernetes.Interface getNode func() (*v1.Node, error) wg sync.WaitGroup
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 20:12:53 UTC 2024 - 16.6K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache-base/src/main/kotlin/org/gradle/internal/cc/base/services/ConfigurationCacheEnvironmentChangeTracker.kt
private var mode: TrackerMode = Initial() private inline fun <T : TrackerMode> setMode(transition: (TrackerMode) -> T): T { synchronized(this) { val newMode = transition(mode) mode = newMode return newMode } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:30 UTC 2024 - 9.5K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/main/kotlin/org/gradle/internal/cc/impl/problems/ConfigurationCacheReport.kt
} private inline fun modifyState(f: State.() -> State) { contract { callsInPlace(f, kotlin.contracts.InvocationKind.EXACTLY_ONCE) } synchronized(stateLock) { state = state.f() } } /** * A heuristic to get the same hash for different instances of an exception * occurring at the same location. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:30 UTC 2024 - 11.4K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/process/internal/worker/child/WorkerProcessClassPathProvider.java
this.moduleRegistry = moduleRegistry; } @Override public ClassPath findClassPath(String name) { if (name.equals("WORKER_MAIN")) { synchronized (lock) { if (workerClassPath == null) { PersistentCache workerClassPathCache = cacheBuilderFactory .createCacheBuilder("workerMain")
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Jun 10 14:28:48 UTC 2024 - 11.1K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/main/kotlin/org/gradle/internal/cc/impl/fingerprint/ConfigurationCacheFingerprintWriter.kt
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:30 UTC 2024 - 32.8K bytes - Viewed (0) -
tensorflow/compiler/jit/xla_device_context.cc
!transfer_manager_->CanShapedBufferBeAccessedNow( stream_->parent(), xla_tensor->shaped_buffer())) { // Initially wait for the compute stream so that memory allocations are // synchronized. TF_RETURN_IF_ERROR(host_to_device_stream_->WaitFor(stream_.get())); } TF_RETURN_IF_ERROR(transfer_manager_->TransferLiteralToDeviceAsync(
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu May 16 00:36:08 UTC 2024 - 12.7K bytes - Viewed (0) -
cmd/erasure-healing-common_test.go
t.Errorf("Unexpected error: %v", dataErrsPerDisk[diskIndex]) } if disk == nil { t.Errorf("Drive erroneously filtered, driveIndex: %d", diskIndex) } } // Test 2: Not synchronized modtime partsMetadataBackup := partsMetadata[0] partsMetadata[0].ModTime = partsMetadata[0].ModTime.Add(-1 * time.Hour) errs = make([]error, len(erasureDisks))
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 23K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/service/DefaultServiceRegistry.java
owner.ownServices.instanceRealized(this, instance); } public final Object getInstance() { Object result = instance; if (result == null) { synchronized (this) { result = instance; if (result == null) { setInstance(createServiceInstance()); result = instance; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:40 UTC 2024 - 53.3K bytes - Viewed (0)