- Sort Score
- Num 10 results
- Language All
Results 241 - 250 of 805 for threadId (0.06 seconds)
-
guava-gwt/src-super/com/google/common/escape/super/com/google/common/escape/Platform.java
static char[] charBufferFromThreadLocal() { // ThreadLocal is not available to GWT, so we always reuse the same // instance. It is always safe to return the same instance because // javascript is single-threaded, and only used by blocks that doesn't // involve async callbacks. return CHAR_BUFFER; } private Platform() {}
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Jan 18 02:54:30 GMT 2025 - 1.1K bytes - Click Count (0) -
src/test/java/jcifs/tests/persistent/HandleInfoTest.java
null); assertFalse(durableInfo.isExpired()); // Wait for expiration try { Thread.sleep(150); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } assertTrue(durableInfo.isExpired()); // Test persistent handle (never expires)Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 21 04:51:33 GMT 2025 - 4.6K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/collect/LockHeldAssertingSet.java
assertTrue(Thread.holdsLock(mutex)); return super.add(o); } @Override public boolean addAll(Collection<? extends E> c) { assertTrue(Thread.holdsLock(mutex)); return super.addAll(c); } @Override public void clear() { assertTrue(Thread.holdsLock(mutex)); super.clear(); } @Override public boolean contains(@Nullable Object o) { assertTrue(Thread.holdsLock(mutex));
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Feb 13 17:34:21 GMT 2025 - 4.3K bytes - Click Count (0) -
guava-tests/test/com/google/common/collect/LockHeldAssertingSet.java
assertTrue(Thread.holdsLock(mutex)); return super.add(o); } @Override public boolean addAll(Collection<? extends E> c) { assertTrue(Thread.holdsLock(mutex)); return super.addAll(c); } @Override public void clear() { assertTrue(Thread.holdsLock(mutex)); super.clear(); } @Override public boolean contains(@Nullable Object o) { assertTrue(Thread.holdsLock(mutex));
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Feb 13 17:34:21 GMT 2025 - 4.4K bytes - Click Count (0) -
.github/workflows/lock.yml
name: 'Lock Threads' on: schedule: - cron: '0 0 * * *' workflow_dispatch: permissions: issues: write concurrency: group: lock jobs: action: runs-on: ubuntu-latest steps: - uses: dessant/lock-threads@v3 with: github-token: ${{ github.token }} issue-inactive-days: '365' exclude-any-issue-labels: 'do-not-close'Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Jan 30 03:27:43 GMT 2022 - 447 bytes - Click Count (0) -
guava-tests/test/com/google/common/collect/SynchronizedMapTest.java
} @Override public int size() { assertTrue(Thread.holdsLock(mutex)); return super.size(); } @Override public boolean isEmpty() { assertTrue(Thread.holdsLock(mutex)); return super.isEmpty(); } @Override public @Nullable V remove(Object object) { assertTrue(Thread.holdsLock(mutex)); return super.remove(object); } @OverrideCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Mar 13 13:01:07 GMT 2026 - 6K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java
Thread.currentThread().interrupt(); // better than `end > System.nanoTime()` because `System.nanoTime()` could wrap around return end - System.nanoTime() > 0; } } /** Invokes {@code toJoin.}{@link Thread#join() join()} uninterruptibly. */ @J2ktIncompatible @GwtIncompatible // concurrency public static void joinUninterruptibly(Thread toJoin) { boolean interrupted = false; try {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Jan 29 23:24:32 GMT 2026 - 22.5K bytes - Click Count (0) -
guava-tests/test/com/google/common/collect/QueuesTest.java
} } } private static class Interrupter implements Runnable { final Thread threadToInterrupt; Interrupter(Thread threadToInterrupt) { this.threadToInterrupt = threadToInterrupt; } @Override public void run() { try { Thread.sleep(100); } catch (InterruptedException e) { throw new AssertionError(); } finally {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Nov 04 17:24:58 GMT 2025 - 12.6K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java
// Run a task on the composed Executor that interrupts its thread (i.e. this thread). fakePool.execute(() -> Thread.currentThread().interrupt()); // Run a task that expects that it is not interrupted while it is running. e.execute(() -> assertThat(Thread.currentThread().isInterrupted()).isFalse()); // Run these together. fakePool.runAll();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) -
src/test/java/jcifs/smb/SmbFileIntegrationTest.java
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 56K bytes - Click Count (0)