Search Options

Results per page
Sort
Preferred Languages
Advance

Results 151 - 160 of 635 for thread (0.07 sec)

  1. guava/src/com/google/common/io/Resources.java

       * context class loader will find resources from the class path. In environments where different
       * threads can have different class loaders, for example app servers, the context class loader
       * will typically have been set to an appropriate loader for the current thread.
       *
       * <p>In the unusual case where the context class loader is null, the class loader that loaded
       * this class ({@code Resources}) will be used instead.
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Aug 02 13:50:22 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/collect/Interners.java

              /* Someone beat us to it! Trying again...
               *
               * Technically this loop not guaranteed to terminate, so theoretically (extremely
               * unlikely) this thread might starve, but even then, there is always going to be another
               * thread doing progress here.
               */
            }
          }
        }
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Mar 13 14:30:51 UTC 2023
    - 5.9K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/AtomicDoubleTest.java

          assertBitEquals(x, at.get());
          prev = x;
        }
      }
    
      /** compareAndSet in one thread enables another waiting for value to succeed */
      public void testCompareAndSetInMultipleThreads() throws Exception {
        final AtomicDouble at = new AtomicDouble(1.0);
        Thread t =
            newStartedThread(
                new CheckedRunnable() {
                  @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  4. guava/src/com/google/common/collect/ForwardingSortedMap.java

     * equality for both keys and values, unlike {@code ForwardingMap}.
     *
     * <p>The {@code standard} methods and the collection views they return are not guaranteed to be
     * thread-safe, even when all of the methods that they depend on are thread-safe.
     *
     * @author Mike Bostock
     * @author Louis Wasserman
     * @since 2.0
     */
    @GwtCompatible
    @ElementTypesAreNonnullByDefault
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 15:26:39 UTC 2023
    - 5.6K bytes
    - Viewed (0)
  5. fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/CrawlerTest.java

                        break;
                    }
                    Thread.sleep(500);
                }
                assertEquals(CrawlerStatus.RUNNING, crawler1.crawlerContext.getStatus());
                for (int i = 0; i < 10; i++) {
                    if (crawler2.crawlerContext.getStatus() == CrawlerStatus.RUNNING) {
                        break;
                    }
                    Thread.sleep(500);
                }
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/util/concurrent/AbstractExecutionThreadServiceTest.java

      private final CountDownLatch exitRun = new CountDownLatch(1);
    
      private Thread executionThread;
      private Throwable thrownByExecutionThread;
      private final Executor exceptionCatchingExecutor =
          new Executor() {
            @Override
            public void execute(Runnable command) {
              executionThread = new Thread(command);
              executionThread.setUncaughtExceptionHandler(
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/eventbus/SubscriberRegistry.java

           * UncheckedExecutionException, which has the stack trace from this thread and which has its
           * cause set to the underlying exception (which may be from another thread). If we someday
           * learn that some other exception besides IllegalArgumentException is common, then we could
           * add another special case to throw an instance of it, too.
           */
          throw e;
        }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 15:16:45 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/TestPlatform.java

        } catch (ExecutionException e) {
          throw new AssertionError(e);
        }
      }
    
      static void verifyThreadWasNotInterrupted() {
        assertFalse(Thread.currentThread().isInterrupted());
      }
    
      static void clearInterrupt() {
        Thread.interrupted();
      }
    
      /**
       * Retrieves the result of a {@code Future} known to be done but uses the {@code get(long,
       * TimeUnit)} overload in order to test that method.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed May 29 16:29:37 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  9. guava/src/com/google/common/collect/ForwardingSet.java

     * invoke methods, they invoke methods on the {@code ForwardingSet}.
     *
     * <p>The {@code standard} methods are not guaranteed to be thread-safe, even when all of the
     * methods that they depend on are thread-safe.
     *
     * @author Kevin Bourrillion
     * @author Louis Wasserman
     * @since 2.0
     */
    @GwtCompatible
    @ElementTypesAreNonnullByDefault
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jun 29 19:42:21 UTC 2021
    - 3.8K bytes
    - Viewed (0)
  10. fess-crawler/src/test/java/org/codelibs/fess/crawler/client/smb1/SmbClientTest.java

            SmbClient client = new SmbClient() {
                @Override
                protected ResponseData getResponseData(final String uri, final boolean includeContent) {
                    try {
                        Thread.sleep(10000);
                    } catch (InterruptedException e) {
                        throw new CrawlingAccessException(e);
                    }
                    return null;
                }
            };
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 2.3K bytes
    - Viewed (0)
Back to top