Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for reentrant (0.26 sec)

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

            if (submittingTaskQueue.thread == submitting) {
              sequencer = null;
              // Submit from inside a reentrant submit. We don't know if this one will be reentrant (and
              // can't know without submitting something to the executor) so queue to run iteratively.
              // Task must be null, since each execution on this executor can only produce one more
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 01 21:46:34 GMT 2024
    - 22.1K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/ConnectionListener.kt

     *
     * All event methods must execute fast, without external locking, cannot throw exceptions,
     * attempt to mutate the event parameters, or be reentrant back into the client.
     * Any IO - writing to files or network should be done asynchronously.
     */
    @ExperimentalOkHttpApi
    abstract class ConnectionListener {
      /**
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Tue Jan 23 14:31:42 GMT 2024
    - 2.2K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/eventbus/Dispatcher.java

              @Override
              protected Queue<Event> initialValue() {
                return Queues.newArrayDeque();
              }
            };
    
        /** Per-thread dispatch state, used to avoid reentrant event dispatching. */
        private final ThreadLocal<Boolean> dispatching =
            new ThreadLocal<Boolean>() {
              @Override
              protected Boolean initialValue() {
                return false;
              }
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Fri Dec 15 19:31:54 GMT 2023
    - 7.3K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/Monitor.java

                      (startTime == 0L) ? timeoutNanos : remainingNanos(startTime, timeoutNanos),
                      reentrant);
          threw = false;
          return satisfied;
        } finally {
          if (!satisfied) {
            try {
              // Don't need to signal if timed out, but do if interrupted
              if (threw && !reentrant) {
                signalNextWaiter();
              }
            } finally {
              lock.unlock();
    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)
  5. android/guava-tests/test/com/google/common/collect/AbstractIteratorTest.java

              }
            };
        try {
          iter.hasNext();
          fail();
        } catch (IllegalStateException expected) {
        }
      }
    
      // Technically we should test other reentrant scenarios (9 combinations of
      // hasNext/next/peek), but we'll cop out for now, knowing that peek() and
      // next() both start by invoking hasNext() anyway.
    
      /** Throws an undeclared checked exception. */
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Feb 21 10:16:44 GMT 2024
    - 8.7K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/collect/AbstractIteratorTest.java

              }
            };
        try {
          iter.hasNext();
          fail();
        } catch (IllegalStateException expected) {
        }
      }
    
      // Technically we should test other reentrant scenarios (9 combinations of
      // hasNext/next/peek), but we'll cop out for now, knowing that peek() and
      // next() both start by invoking hasNext() anyway.
    
      /** Throws an undeclared checked exception. */
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Wed Feb 21 10:16:44 GMT 2024
    - 8.7K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java

      }
    
      public void testReentrancy_noDeadlock() {
        lockA.lock();
        lockB.lock();
        lockA.lock(); // Should not assert on lockB -> reentrant(lockA)
      }
    
      public void testExplicitOrdering_noViolations() {
        lock1.lock();
        lock3.lock();
        lock3.unlock();
        lock2.lock();
        lock3.lock();
      }
    
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 16.1K bytes
    - Viewed (1)
  8. guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java

      }
    
      public void testReentrancy_noDeadlock() {
        lockA.lock();
        lockB.lock();
        lockA.lock(); // Should not assert on lockB -> reentrant(lockA)
      }
    
      public void testExplicitOrdering_noViolations() {
        lock1.lock();
        lock3.lock();
        lock3.unlock();
        lock2.lock();
        lock3.lock();
      }
    
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 16.1K bytes
    - Viewed (0)
  9. ci/official/containers/linux_arm64/builder.devtoolset/gcc9-fixups.patch

    --- a/locale/xlocale.h
    +++ b/locale/xlocale.h
    @@ -20,6 +20,9 @@
     #ifndef _XLOCALE_H
     #define _XLOCALE_H	1
     
    +#ifndef _BITS_TYPES___LOCALE_T_H
    +#define _BITS_TYPES___LOCALE_T_H 1
    +
     /* Structure for reentrant locale using functions.  This is an
        (almost) opaque type for the user level programs.  The file and
        this data structure is not standardized.  Don't rely on it.  It can
    @@ -41,4 +44,6 @@ typedef struct __locale_struct
    Others
    - Registered: Tue May 07 12:40:20 GMT 2024
    - Last Modified: Mon Sep 18 14:52:45 GMT 2023
    - 8.9K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java

       *
       * lockA.lock();
       *
       * lockB.lock();  // will throw an IllegalStateException
       * lockC.lock();  // will throw an IllegalStateException
       *
       * lockA.lock();  // reentrant acquisition is okay
       * }</pre>
       *
       * <p>It is the responsibility of the application to ensure that multiple lock instances with the
       * same rank are never acquired in the same thread.
       *
    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