Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 441 - 450 of 890 for thread (0.27 seconds)

  1. README.md

    **Suggestions Not Appearing**
    - Confirm documents are indexed: `suggester.refresh()`
    - Check query formatting and filters
    - Verify analyzer configurations
    
    **Performance Issues**
    - Increase thread pool size in SuggesterBuilder
    - Optimize batch sizes for indexing operations
    - Review OpenSearch cluster performance
    
    **Memory Usage**
    - Configure appropriate JVM heap settings
    Created: Fri Apr 17 09:08:13 GMT 2026
    - Last Modified: Sun Aug 31 03:31:14 GMT 2025
    - 12.1K bytes
    - Click Count (1)
  2. src/test/java/jcifs/SmbSessionTest.java

                java.util.concurrent.atomic.AtomicInteger successCount = new java.util.concurrent.atomic.AtomicInteger(0);
    
                for (int i = 0; i < 5; i++) {
                    new Thread(() -> {
                        try {
                            Configuration result = mockSession.getConfig();
                            if (result == mockConfig) {
                                successCount.incrementAndGet();
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 15.1K bytes
    - Click Count (0)
  3. build-logic/cleanup/src/main/java/gradlebuild/cleanup/services/KillLeakingJavaProcesses.java

            ByteArrayOutputStream os = new ByteArrayOutputStream();
            PrintStream ps = new PrintStream(os, true);
            new Thread(() -> {
                try {
                    BufferedReader reader = new BufferedReader(new InputStreamReader(forkedProcessOutput, UTF_8));
                    String line;
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Tue Sep 23 13:49:45 GMT 2025
    - 12K bytes
    - Click Count (0)
  4. api/maven-api-core/src/main/java/org/apache/maven/api/package-info.java

     *
     * <p>The {@link org.apache.maven.api.Session} interface is the main entry point for Maven operations.
     * It maintains the state of a Maven execution and provides access to all core services and components.
     * Sessions are thread-safe and can be obtained in session-scoped components using the
     * {@link org.apache.maven.api.di.SessionScoped} annotation.</p>
     *
     * <p>Key capabilities provided through the Session include:</p>
     * <ul>
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Mon Dec 15 11:13:42 GMT 2025
    - 7.7K bytes
    - Click Count (0)
  5. src/main/java/jcifs/util/SecureCredentialStorage.java

     * using AES-GCM encryption with PBKDF2 key derivation.
     *
     * Features:
     * - Encrypts credentials at rest using AES-256-GCM
     * - Uses PBKDF2 for key derivation from master password
     * - Secure wiping of sensitive data
     * - Thread-safe operations
     * - Protection against timing attacks
     */
    public class SecureCredentialStorage implements AutoCloseable, Destroyable {
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 12.7K bytes
    - Click Count (0)
  6. guava-tests/test/com/google/common/io/MoreFilesTest.java

          MoreFiles.deleteDirectoryContents(symlink, ALLOW_INSECURE);
          assertEquals(0, MoreFiles.listFiles(dir).size());
        }
      }
    
      /**
       * This test attempts to create a situation in which one thread is constantly changing a file from
       * being a real directory to being a symlink to another directory. It then calls
       * deleteDirectoryContents thousands of times on a directory whose subtree contains the file
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 17 19:26:39 GMT 2026
    - 27.5K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/util/concurrent/Service.java

       * @param executor the executor in which the listeners callback methods will be run. For fast,
       *     lightweight listeners that would be safe to execute in any thread, consider {@link
       *     MoreExecutors#directExecutor}.
       * @since 13.0
       */
      void addListener(Listener listener, Executor executor);
    
      /**
       * The lifecycle states of a service.
       *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Dec 21 03:10:51 GMT 2024
    - 10.8K bytes
    - Click Count (0)
  8. guava/src/com/google/common/cache/CacheLoader.java

       * @throws InterruptedException if this method is interrupted. {@code InterruptedException} is
       *     treated like any other {@code Exception} in all respects except that, when it is caught,
       *     the thread's interrupted status is set
       */
      public abstract V load(K key) throws Exception;
    
      /**
       * Computes or retrieves a replacement value corresponding to an already-cached {@code key}. This
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jan 28 22:39:02 GMT 2026
    - 9.5K bytes
    - Click Count (0)
  9. android/guava/src/com/google/common/util/concurrent/AbstractFuture.java

        //    executing listeners in the order they were added
        // 3. push all the items onto 'onto' and return the new head of the stack
        Listener head = gasListeners(Listener.TOMBSTONE);
        Listener reversedList = onto;
        while (head != null) {
          Listener tmp = head;
          head = head.next;
          tmp.next = reversedList;
          reversedList = tmp;
        }
        return reversedList;
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 14:39:00 GMT 2026
    - 43.6K bytes
    - Click Count (0)
  10. mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/MockWebServerTest.kt

        assertThat(inputStream.read()).isEqualTo('A'.code)
        assertThat(inputStream.read()).isEqualTo('B'.code)
        assertThat(inputStream.read()).isEqualTo('C'.code)
        assertThat(inputStream.read()).isEqualTo('D'.code)
        assertThat(inputStream.read()).isEqualTo('E'.code)
        assertThat(inputStream.read()).isEqualTo('F'.code)
        assertThat(inputStream.read()).isEqualTo(-1)
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Thu Jul 03 13:16:34 GMT 2025
    - 22.3K bytes
    - Click Count (0)
Back to Top