- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 121 for SYNCHRONIZE (0.17 sec)
-
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/CacheAccessSerializer.java
return synchronizer.synchronize(() -> cache.get(key, factory)); } @Override public V getIfPresent(K key) { return synchronizer.synchronize(() -> cache.getIfPresent(key)); } @Override public void put(K key, V value) { synchronizer.synchronize(() -> cache.put(key, value)); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 19:07:35 UTC 2024 - 1.4K bytes - Viewed (0) -
pkg/kubelet/eviction/eviction_manager_test.go
_, err = manager.synchronize(diskInfoProvider, activePodsFunc) if err != nil { t.Fatalf("Manager should not have an error %v", err) } // we should not have disk pressure if manager.IsUnderDiskPressure() { t.Fatalf("Manager should not report disk pressure") } // synchronize _, err = manager.synchronize(diskInfoProvider, activePodsFunc)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 15 23:14:12 UTC 2024 - 119.9K bytes - Viewed (0) -
src/runtime/proflabel.go
// is important because profBuf.read will observe different // labels set by different setProfLabel operations on // different goroutines, so it needs to synchronize with all // of them (this wouldn't be an issue if we could synchronize // on &getg().labels since we would synchronize with each // most-recent labels write separately.) // // racereleasemerge is like a full read-modify-write on
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 16:25:21 UTC 2024 - 2.1K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/Synchronizer.java
@NonNullApi public class Synchronizer { private final Lock lock = new ReentrantLock(); public <T> T synchronize(Supplier<T> factory) { lock.lock(); try { return factory.get(); } finally { lock.unlock(); } } public void synchronize(Runnable operation) { lock.lock(); try { operation.run(); } finally {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 19:07:35 UTC 2024 - 1.3K bytes - Viewed (0) -
.github/workflows/docs.yml
name: docs on: push: branches: - master pull_request: types: [opened, labeled, unlabeled, synchronize] permissions: contents: read env: GRADLE_OPTS: "-Dorg.gradle.jvmargs=-Xmx4g -Dorg.gradle.daemon=false -Dkotlin.incremental=false" jobs: test_docs: permissions: checks: write # for actions/upload-artifact runs-on: ubuntu-latest
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Mar 04 06:13:36 UTC 2024 - 1K bytes - Viewed (0) -
.github/workflows/containers.yml
name: containers on: push: branches: - master pull_request: types: [opened, labeled, unlabeled, synchronize] permissions: contents: read env: GRADLE_OPTS: "-Dorg.gradle.jvmargs=-Xmx4g -Dorg.gradle.daemon=false -Dkotlin.incremental=false" jobs: test_containers: permissions: checks: write # for actions/upload-artifact runs-on: ubuntu-latest
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Mar 23 12:00:11 UTC 2024 - 911 bytes - Viewed (0) -
.github/workflows/test-redistribute.yml
name: Test Redistribute on: push: branches: - master pull_request: types: - opened - synchronize jobs: test-redistribute: runs-on: ubuntu-latest strategy: matrix: package: - fastapi - fastapi-slim steps: - name: Dump GitHub context env: GITHUB_CONTEXT: ${{ toJson(github) }}
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Tue May 07 18:31:27 UTC 2024 - 1.4K bytes - Viewed (0) -
tensorflow/compiler/jit/xla_host_send_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.6K bytes - Viewed (0) -
pkg/kubelet/eviction/eviction_manager.go
go func() { for { evictedPods, err := m.synchronize(diskInfoProvider, podFunc) if evictedPods != nil && err == nil { klog.InfoS("Eviction manager: pods evicted, waiting for pod to be cleaned up", "pods", klog.KObjSlice(evictedPods)) m.waitForPodsCleanup(podCleanedUpFunc, evictedPods) } else { if err != nil { klog.ErrorS(err, "Eviction manager: failed to synchronize") } time.Sleep(monitoringInterval)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 27 18:55:56 UTC 2024 - 24.6K bytes - Viewed (0) -
.github/workflows/check-bad-merge.yml
# See .github/workflows/CheckBadMerge.groovy for explanation name: Check bad merge commit on: pull_request: types: - opened - synchronize permissions: {} jobs: check_pr_commits: permissions: contents: read runs-on: ubuntu-latest steps: - name: Checkout code uses: actions/checkout@v4 with: fetch-depth: 0 - name: Set up JDK 11
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 02 09:13:16 UTC 2024 - 1.7K bytes - Viewed (0)