Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 566 for Lock (0.29 sec)

  1. ci/official/wheel_test/README.md

    to the actual TensorFlow wheel.
    3. Creates a `requirements_lock_<python_version>.txt` file.
    4. Updates the `requirements_lock_<python_version>.txt` file using
    a Bazel command.
    5. Moves the updated `requirements_lock_<python_version>.txt` file
    to the `../wheel_test/` directory.
    
    
    ### How it Works in the Presubmit Job
    
    `_requirements_lock` files will be generated by the presubmit job. A detailed
    Plain Text
    - Registered: Tue Apr 30 12:39:09 GMT 2024
    - Last Modified: Thu Aug 31 18:17:57 GMT 2023
    - 3.3K bytes
    - Viewed (0)
  2. maven-compat/src/main/java/org/apache/maven/repository/legacy/DefaultUpdateCheckManager.java

                    return;
                }
    
                FileChannel channel = null;
                FileLock lock = null;
                try {
                    Properties props = new Properties();
    
                    channel = new RandomAccessFile(touchfile, "rw").getChannel();
                    lock = channel.lock();
    
                    if (touchfile.canRead()) {
    Java
    - Registered: Sun May 05 03:35:11 GMT 2024
    - Last Modified: Wed Sep 06 11:28:54 GMT 2023
    - 12.1K bytes
    - Viewed (0)
  3. okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt

      }
    
      private fun logEvent(e: ConnectionEvent) {
        if (e.connection != null) {
          assertThat(Thread.holdsLock(e.connection), "Called with lock $${e.connection}")
            .isFalse()
        }
        for (lock in forbiddenLocks) {
          assertThat(Thread.holdsLock(lock), "Called with lock $lock")
            .isFalse()
        }
    
        if (enforceOrder) {
          checkForStartEvent(e)
        }
    
        eventSequence.offer(e)
      }
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 5.6K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt

       * be removed from the execution schedule.
       */
      fun cancelAll() {
        lock.assertNotHeld()
    
        taskRunner.lock.withLock {
          if (cancelAllAndDecide()) {
            taskRunner.kickCoordinator(this)
          }
        }
      }
    
      fun shutdown() {
        lock.assertNotHeld()
    
        taskRunner.lock.withLock {
          shutdown = true
          if (cancelAllAndDecide()) {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 7.5K bytes
    - Viewed (0)
  5. cni/pkg/nodeagent/pod_cache.go

    func (p *podNetnsCache) UpsertPodCacheWithNetns(uid string, workload WorkloadInfo) Netns {
    	// lock current snapshot pod map
    	p.mu.Lock()
    	defer p.mu.Unlock()
    	if existing := p.currentPodCache[uid]; existing.Netns != nil {
    		if existing.Netns.Inode() == workload.Netns.Inode() {
    			workload.Netns.Close()
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 4.5K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/util/concurrent/TestThread.java

     * test with reference to the same "lock-like object", and then their interactions with that object
     * are choreographed via the various methods on this class.
     *
     * <p>A "lock-like object" is really any object that may be used for concurrency control. If the
     * {@link #callAndAssertBlocks} method is ever called in a test, the lock-like object must have a
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Apr 26 20:07:17 GMT 2023
    - 10.9K bytes
    - Viewed (0)
  7. .github/workflows/osv-scanner-scheduled.yml

        with:
          scan-args: |-
            --lockfile=requirements.txt:./requirements_lock_3_9.txt
            --lockfile=requirements.txt:./requirements_lock_3_10.txt
            --lockfile=requirements.txt:./requirements_lock_3_11.txt
            --lockfile=requirements.txt:./requirements_lock_3_12.txt
            --lockfile=requirements.txt:./ci/official/containers/linux_arm64/devel.requirements.txt
    Others
    - Registered: Tue May 07 12:40:20 GMT 2024
    - Last Modified: Tue Feb 06 17:09:49 GMT 2024
    - 1.6K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/StripedTest.java

            .add(new Striped.SmallLazyStriped<ReadWriteLock>(50, READ_WRITE_LOCK_SUPPLIER))
            .add(new Striped.SmallLazyStriped<ReadWriteLock>(64, READ_WRITE_LOCK_SUPPLIER))
            .add(new Striped.LargeLazyStriped<ReadWriteLock>(50, READ_WRITE_LOCK_SUPPLIER))
            .add(new Striped.LargeLazyStriped<ReadWriteLock>(64, READ_WRITE_LOCK_SUPPLIER))
            .add(new Striped.SmallLazyStriped<Lock>(50, LOCK_SUPPLER))
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Feb 09 22:57:07 GMT 2022
    - 8.4K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/Monitor.java

        }
        final ReentrantLock lock = this.lock;
        lock.lock();
    
        boolean satisfied = false;
        try {
          return satisfied = guard.isSatisfied();
        } finally {
          if (!satisfied) {
            lock.unlock();
          }
        }
      }
    
      /**
       * Enters this monitor if the guard is satisfied. Blocks at most the given time acquiring the
       * lock, but does not wait for the guard to be satisfied.
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Dec 04 18:22:01 GMT 2023
    - 38.6K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java

       *
       * Lock lockA = factory1.newReentrantLock(MyLockOrder.FIRST);
       * Lock lockB = factory1.newReentrantLock(MyLockOrder.FIRST);
       * Lock lockC = factory2.newReentrantLock(MyLockOrder.FIRST);
       *
       * lockA.lock();
       *
       * lockB.lock();  // will throw an IllegalStateException
       * lockC.lock();  // will throw an IllegalStateException
       *
       * lockA.lock();  // reentrant acquisition is okay
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Fri Dec 15 19:31:54 GMT 2023
    - 35.9K bytes
    - Viewed (0)
Back to top