Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 241 - 250 of 805 for threadId (0.07 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. .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)
  6. 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);
        }
    
        @Override
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Mar 13 13:01:07 GMT 2026
    - 6K bytes
    - Click Count (0)
  7. 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)
  8. 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)
  9. 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)
  10. src/test/java/jcifs/smb/SmbFileIntegrationTest.java

                    if (attempt < 10) {
                        Thread.sleep(500); // First 10 attempts: 0.5 second intervals
                    } else if (attempt < 30) {
                        Thread.sleep(1000); // Next 20 attempts: 1 second intervals
                    } else {
                        Thread.sleep(2000); // Remaining attempts: 2 second intervals
                    }
                }
            }
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 56K bytes
    - Click Count (0)
Back to Top