Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 21 for reentrant (0.11 sec)

  1. 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
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  2. 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
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  3. 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 {
      /**
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue Jan 23 14:31:42 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/Striped.java

        return new CompactStriped<>(stripes, supplier);
      }
    
      /**
       * Creates a {@code Striped<Lock>} with eagerly initialized, strongly referenced locks. Every lock
       * is reentrant.
       *
       * @param stripes the minimum number of stripes (locks) required
       * @return a new {@code Striped<Lock>}
       */
      public static Striped<Lock> lock(int stripes) {
        return custom(stripes, PaddedLock::new);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Jun 26 12:58:35 UTC 2024
    - 20.6K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/base/AbstractIteratorTest.java

                boolean unused = hasNext();
                throw new AssertionError();
              }
            };
        assertThrows(IllegalStateException.class, iter::hasNext);
      }
    
      // Technically we should test other reentrant scenarios (4 combinations of
      // hasNext/next), but we'll cop out for now, knowing that
      // next() both start by invoking hasNext() anyway.
    
      /** Throws an undeclared checked exception. */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Sep 17 18:14:12 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/collect/AbstractIteratorTest.java

                boolean unused = hasNext();
                throw new AssertionError();
              }
            };
        assertThrows(IllegalStateException.class, iter::hasNext);
      }
    
      // 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. */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Oct 15 17:36:06 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/collect/AbstractIteratorTest.java

                boolean unused = hasNext();
                throw new AssertionError();
              }
            };
        assertThrows(IllegalStateException.class, iter::hasNext);
      }
    
      // 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. */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Oct 15 17:36:06 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  8. 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;
              }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Dec 15 19:31:54 UTC 2023
    - 7.3K 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
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Mon Sep 18 14:52:45 UTC 2023
    - 8.9K bytes
    - Viewed (0)
  10. 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();
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 16.1K bytes
    - Viewed (0)
Back to top