- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 35 for wlocked (0.07 seconds)
-
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) -
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) -
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) -
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) -
.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) -
.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_OUTPUTCreated: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Wed Mar 18 15:36:56 GMT 2026 - 4K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java
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) -
guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java
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) -
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) -
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)