Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 541 - 550 of 805 for threadId (0.14 seconds)

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

          run = true;
        }
      }
    
      private static class TestCallable implements Callable<String> {
        @Override
        public String call() {
          return "foo";
        }
      }
    
      /** Simple same thread listening executor service that doesn't handle shutdown. */
      private static class TestListeningExecutorService extends AbstractListeningExecutorService {
    
        @Override
        public void execute(Runnable runnable) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 3.4K bytes
    - Click Count (0)
  2. guava-tests/test/com/google/common/util/concurrent/AbstractListeningExecutorServiceTest.java

          run = true;
        }
      }
    
      private static class TestCallable implements Callable<String> {
        @Override
        public String call() {
          return "foo";
        }
      }
    
      /** Simple same thread listening executor service that doesn't handle shutdown. */
      private static class TestListeningExecutorService extends AbstractListeningExecutorService {
    
        @Override
        public void execute(Runnable runnable) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 3.4K bytes
    - Click Count (0)
  3. impl/maven-cli/src/main/java/org/apache/maven/cling/ClingSupport.java

        /**
         * Ctor that creates "managed" ClassWorld. This constructor is not used in "normal" circumstances.
         */
        public ClingSupport() {
            this(new ClassWorld(CORE_CLASS_REALM_ID, Thread.currentThread().getContextClassLoader()), true);
        }
    
        /**
         * Ctor to be used when running in ClassWorlds Launcher.
         */
        public ClingSupport(ClassWorld classWorld) {
            this(classWorld, false);
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Sat Feb 08 16:25:25 GMT 2025
    - 3.6K bytes
    - Click Count (0)
  4. src/main/resources/fess_message_nl.properties

    errors.invalid_header_for_request_file=Ongeldige headerregel: {0}
    errors.could_not_delete_logged_in_user=Kan ingelogde gebruiker niet verwijderen.
    errors.unauthorized_request=Ongeautoriseerd verzoek.
    errors.failed_to_print_thread_dump=Kan thread-dump niet afdrukken.
    errors.file_is_not_supported={0} wordt niet ondersteund.
    errors.plugin_file_is_not_found={0} niet gevonden.
    errors.failed_to_install_plugin=Kan {0} niet installeren.
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 28 06:59:19 GMT 2026
    - 12.9K bytes
    - Click Count (0)
  5. android/guava-testlib/src/com/google/common/testing/FakeTicker.java

     *
     * <p>The ticker can be configured so that the time is incremented whenever {@link #read} is called:
     * see {@link #setAutoIncrementStep}.
     *
     * <p>This class is thread-safe.
     *
     * @author Jige Yu
     * @since 10.0
     */
    @NullMarked
    @GwtCompatible
    public class FakeTicker extends Ticker {
    
      private final AtomicLong nanos = new AtomicLong();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Apr 14 15:16:19 GMT 2025
    - 4.1K bytes
    - Click Count (0)
  6. src/main/java/org/codelibs/fess/suggest/settings/BadWordSettings.java

            if (defaultWords != null) {
                return;
            }
    
            final List<String> list = new ArrayList<>();
            try (BufferedReader br = new BufferedReader(new InputStreamReader(
                    Thread.currentThread().getContextClassLoader().getResourceAsStream("suggest_settings/default-badwords.txt")))) {
    
                String line;
                while ((line = br.readLine()) != null) {
    Created: Fri Apr 17 09:08:13 GMT 2026
    - Last Modified: Sun Nov 23 03:02:17 GMT 2025
    - 5.3K bytes
    - Click Count (0)
  7. src/test/java/org/codelibs/fess/entity/ChatSessionTest.java

            assertEquals("user-789", session.getUserId());
            assertEquals(createdAt, session.getCreatedAt());
            assertEquals(lastAccessedAt, session.getLastAccessedAt());
            // getMessages() returns a defensive copy for thread-safety
            assertEquals(messages, session.getMessages());
        }
    
        @Test
        public void test_addMessage() {
            final ChatSession session = new ChatSession();
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 07 01:53:06 GMT 2026
    - 12.6K bytes
    - Click Count (0)
  8. fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueServiceTest.java

            final AtomicInteger totalPolled = new AtomicInteger(0);
            final List<String> allUrls = new ArrayList<>();
    
            for (int i = 0; i < numThreads; i++) {
                new Thread(() -> {
                    try {
                        startLatch.await();
                        int count = 0;
                        while (count < itemsPerThread) {
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Wed Jan 14 23:48:16 GMT 2026
    - 14.5K bytes
    - Click Count (0)
  9. android/guava/src/com/google/common/io/PatternFilenameFilter.java

    import java.io.File;
    import java.io.FilenameFilter;
    import java.util.regex.Pattern;
    import java.util.regex.PatternSyntaxException;
    
    /**
     * File name filter that only accepts files matching a regular expression. This class is thread-safe
     * and immutable.
     *
     * @author Apple Chow
     * @since 1.0
     */
    @J2ktIncompatible
    @GwtIncompatible
    public final class PatternFilenameFilter implements FilenameFilter {
    
      private final Pattern pattern;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Dec 21 03:10:51 GMT 2024
    - 2.7K bytes
    - Click Count (1)
  10. compat/maven-compat/src/main/java/org/apache/maven/repository/metadata/DefaultClasspathTransformation.java

            }
        }
    
        // ===================================================================================================
        /**
         * Helper class to traverse graph. Required to make the containing method thread-safe
         * and yet use class level data to lessen stack usage in recursion
         */
        private class ClasspathGraphVisitor {
            MetadataGraph graph;
    
            ClasspathContainer cpc;
    
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Jul 23 17:27:08 GMT 2025
    - 5.1K bytes
    - Click Count (0)
Back to Top