Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 35 for wlocked (0.07 seconds)

  1. android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java

        // after some period of time the runner thread should become blocked on the task because it is
        // waiting for the slow interrupting thread to complete Thread.interrupt
        awaitBlockedOnInstanceOf(runner, InterruptibleTask.Blocker.class);
    
        Blocker blocker = (Blocker) LockSupport.getBlocker(runner);
        Thread owner = blocker.getOwner();
        assertThat(owner).isSameInstanceAs(interrupter);
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 7.2K bytes
    - Click Count (0)
  2. guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java

        // after some period of time the runner thread should become blocked on the task because it is
        // waiting for the slow interrupting thread to complete Thread.interrupt
        awaitBlockedOnInstanceOf(runner, InterruptibleTask.Blocker.class);
    
        Blocker blocker = (Blocker) LockSupport.getBlocker(runner);
        Thread owner = blocker.getOwner();
        assertThat(owner).isSameInstanceAs(interrupter);
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 7.2K bytes
    - Click Count (0)
  3. internal/stmt_store/stmt_store.go

    	//   locker: A synchronization lock that is unlocked after initialization to avoid deadlocks.
    	// Returns:
    	//   *Stmt: A newly created statement object for executing SQL operations.
    	//   error: An error if the statement preparation fails.
    	New(ctx context.Context, key string, isTransaction bool, connPool ConnPool, locker sync.Locker) (*Stmt, error)
    
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Sat Mar 21 11:35:55 GMT 2026
    - 6.1K bytes
    - Click Count (0)
  4. src/test/java/org/codelibs/fess/mylasta/direction/sponsor/FessCurtainBeforeHookTest.java

            // This test verifies that the DBFluteSystem is properly unlocked and locked
            // during the process, though we can't directly test the lock state
    
            // When
            try {
                curtainBeforeHook.processDBFluteSystem();
    
                // Then - if we get here without exception, the unlock/lock worked
                DfFinalTimeZoneProvider provider = getDBFluteSystemTimeZoneProvider();
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 8.4K bytes
    - Click Count (0)
  5. .github/workflows/build-docs.yml

            uses: astral-sh/setup-uv@v7
            with:
              enable-cache: true
              cache-dependency-glob: |
                pyproject.toml
                uv.lock
          - name: Install docs extras
            run: uv sync --locked --no-dev --group docs
          - name: Export Language Codes
            id: show-langs
            run: |
              echo "langs=$(uv run ./scripts/docs.py langs-json)" >> $GITHUB_OUTPUT
    
      build-docs:
        needs:
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Sat Mar 14 15:01:34 GMT 2026
    - 3.3K bytes
    - Click Count (0)
  6. .github/workflows/translate.yml

          - name: Setup uv
            uses: astral-sh/setup-uv@v7
            with:
              cache-dependency-glob: |
                pyproject.toml
                uv.lock
          - name: Install Dependencies
            run: uv sync --locked --no-dev --group github-actions --group translations
          - name: Export Language Codes
            id: show-langs
            run: |
              echo "langs=$(uv run ./scripts/translate.py llm-translatable-json)" >> $GITHUB_OUTPUT
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Wed Mar 18 15:36:56 GMT 2026
    - 4K bytes
    - Click Count (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java

        ReentrantLock lockD = otherFactory.newReentrantLock("LockD");
    
        // lockA -> lockD
        lockA.lock();
        lockD.lock();
        lockA.unlock();
        lockD.unlock();
    
        // lockD -> lockA should fail even though lockD is from a different factory.
        lockD.lock();
        PotentialDeadlockException expected =
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 16.3K bytes
    - Click Count (0)
  8. guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java

        ReentrantLock lockD = otherFactory.newReentrantLock("LockD");
    
        // lockA -> lockD
        lockA.lock();
        lockD.lock();
        lockA.unlock();
        lockD.unlock();
    
        // lockD -> lockA should fail even though lockD is from a different factory.
        lockD.lock();
        PotentialDeadlockException expected =
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 16.3K bytes
    - Click Count (0)
  9. guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

      private static final long SMALL_TIMEOUT_MILLIS = 10;
    
      /** How long to wait when determining that a thread is blocked if we expect it to be blocked. */
      private static final long EXPECTED_HANG_DELAY_MILLIS = 75;
    
      /**
       * How long to wait when determining that a thread is blocked if we DON'T expect it to be blocked.
       */
      private static final long UNEXPECTED_HANG_DELAY_MILLIS = 10000;
    
      /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 26.7K bytes
    - Click Count (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

                }
                throw new RejectedExecutionException();
              }
            };
        SequentialExecutor executor = new SequentialExecutor(delegate);
        ExecutorService blocked = newCachedThreadPool();
        Future<?> first = blocked.submit(() -> executor.execute(Runnables.doNothing()));
        future.get(10, SECONDS);
        assertThrows(RejectedExecutionException.class, () -> executor.execute(Runnables.doNothing()));
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 10.5K bytes
    - Click Count (0)
Back to Top