Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for isHeldByCurrentThread (0.21 sec)

  1. android/guava/src/com/google/common/util/concurrent/Monitor.java

        if (guard.monitor != this) {
          throw new IllegalMonitorStateException();
        }
        final ReentrantLock lock = this.lock;
        boolean signalBeforeWaiting = lock.isHeldByCurrentThread();
        lock.lockInterruptibly();
    
        boolean satisfied = false;
        try {
          if (!guard.isSatisfied()) {
            await(guard, signalBeforeWaiting);
          }
          satisfied = true;
    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)
  2. okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt

        if (assertionsEnabled && !taskRunner.lock.isHeldByCurrentThread) {
          throw AssertionError("Thread ${Thread.currentThread().name} MUST hold lock on $this")
        }
      }
    
      @Suppress("NOTHING_TO_INLINE")
      internal inline fun Any.assertThreadDoesntHoldLock() {
        if (assertionsEnabled && taskRunner.lock.isHeldByCurrentThread) {
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Thu Apr 11 22:09:35 GMT 2024
    - 12.5K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/-UtilJvm.kt

      OkHttpClient::class.java.name.removePrefix("okhttp3.").removeSuffix("Client")
    
    @Suppress("NOTHING_TO_INLINE")
    internal inline fun ReentrantLock.assertHeld() {
      if (assertionsEnabled && !this.isHeldByCurrentThread) {
        throw AssertionError("Thread ${Thread.currentThread().name} MUST hold lock on $this")
      }
    }
    
    @Suppress("NOTHING_TO_INLINE")
    internal inline fun Any.assertThreadHoldsLock() {
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Tue Jan 09 12:33:05 GMT 2024
    - 10.5K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java

        @Override
        public LockGraphNode getLockGraphNode() {
          return lockGraphNode;
        }
    
        @Override
        public boolean isAcquiredByCurrentThread() {
          return isHeldByCurrentThread();
        }
    
        ///// Overridden ReentrantLock methods. /////
    
        @Override
        public void lock() {
          aboutToAcquire(this);
          try {
            super.lock();
          } finally {
    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)
  5. android/guava/src/com/google/common/cache/LocalCache.java

                  return true;
                }
                return false;
              }
            }
    
            return false;
          } finally {
            unlock();
            if (!isHeldByCurrentThread()) { // don't clean up inside of put
              postWriteCleanup();
            }
          }
        }
    
        @CanIgnoreReturnValue
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 22 17:40:56 GMT 2024
    - 144.7K bytes
    - Viewed (0)
  6. guava/src/com/google/common/cache/LocalCache.java

                  return true;
                }
                return false;
              }
            }
    
            return false;
          } finally {
            unlock();
            if (!isHeldByCurrentThread()) { // don't clean up inside of put
              postWriteCleanup();
            }
          }
        }
    
        @CanIgnoreReturnValue
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Thu Feb 22 17:40:56 GMT 2024
    - 150.3K bytes
    - Viewed (0)
Back to top