Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 31 - 40 of 942 for Threads (0.06 seconds)

  1. src/test/java/jcifs/internal/smb2/Smb2SigningDigestTest.java

                    Arrays.fill(dataArrays[i], (byte) i);
    
                    threads[i] = new Thread(() -> {
                        digest.sign(dataArrays[index], 0, dataArrays[index].length, request, response);
                    });
                }
    
                for (Thread t : threads) {
                    t.start();
                }
                for (Thread t : threads) {
                    t.join();
                }
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 43.7K bytes
    - Click Count (0)
  2. src/test/java/jcifs/internal/dfs/DfsReferralRequestBufferTest.java

                // Create multiple threads to call size()
                Thread[] threads = new Thread[10];
                for (int i = 0; i < threads.length; i++) {
                    threads[i] = new Thread(() -> {
                        for (int j = 0; j < 1000; j++) {
                            assertEquals(expectedSize, buffer.size());
                        }
                    });
                    threads[i].start();
                }
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 17.5K bytes
    - Click Count (0)
  3. src/main/java/org/codelibs/fess/app/web/api/admin/stats/ApiAdminStatsAction.java

                return jvmGcObj;
            }).toArray(n -> new JvmGcObj[n]);
            final Threads threads = jvmStats.getThreads();
            final JvmThreadsObj jvmThreadsObj = new JvmThreadsObj();
            jvmObj.threads = jvmThreadsObj;
            jvmThreadsObj.count = threads.getCount();
            jvmThreadsObj.peak = threads.getPeakCount();
            final Classes classes = jvmStats.getClasses();
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 19.7K bytes
    - Click Count (0)
  4. guava-tests/test/com/google/common/util/concurrent/TestThread.java

       * intentionally, so there is no other way to clean up these threads. (The better solution,
       * though, would be to run the tests that use TestThread in separate VMs so that their threads
       * don't hang around during other tests.)
       */
      @Override
      public void tearDown() throws Exception {
        try {
          Thread.class.getMethod("stop").invoke(this);
          join();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Mar 13 13:01:07 GMT 2026
    - 11.5K bytes
    - Click Count (0)
  5. src/test/java/jcifs/internal/smb1/trans2/Trans2QueryFSInformationTest.java

                        success[index] = false;
                    }
                });
                threads[i].start();
            }
    
            // Wait for all threads to complete
            for (Thread thread : threads) {
                thread.join();
            }
    
            // All threads should complete successfully
            for (boolean s : success) {
                assertTrue(s);
            }
        }
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 18.9K bytes
    - Click Count (0)
  6. src/test/java/jcifs/internal/smb1/trans2/Trans2SetFileInformationTest.java

                        success[index] = false;
                    }
                });
                threads[i].start();
            }
    
            // Wait for all threads to complete
            for (Thread thread : threads) {
                thread.join();
            }
    
            // All threads should complete successfully
            for (boolean s : success) {
                assertTrue(s);
            }
        }
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 17.8K bytes
    - Click Count (0)
  7. src/test/java/org/codelibs/fess/mylasta/direction/sponsor/FessCurtainFinallyHookTest.java

                    }
                });
            }
    
            // Start all threads
            for (Thread thread : threads) {
                thread.start();
            }
    
            // Wait for all threads to complete
            for (Thread thread : threads) {
                thread.join(5000); // 5 second timeout
            }
    
            // Verify no errors occurred during concurrent execution
            assertFalse(hasError.get());
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 8.7K bytes
    - Click Count (0)
  8. src/test/java/jcifs/internal/smb2/Smb2EchoRequestTest.java

            @DisplayName("Should maintain thread safety")
            void testThreadSafety() throws InterruptedException {
                int threadCount = 10;
                Thread[] threads = new Thread[threadCount];
                boolean[] success = new boolean[threadCount];
    
                for (int i = 0; i < threadCount; i++) {
                    final int index = i;
                    threads[i] = new Thread(() -> {
                        try {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 11.3K bytes
    - Click Count (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/CallablesTest.java

      }
    
      @J2ktIncompatible
      @GwtIncompatible // threads
      public void testRenaming() throws Exception {
        String oldName = Thread.currentThread().getName();
        Supplier<String> newName = Suppliers.ofInstance("MyCrazyThreadName");
        Callable<@Nullable Void> callable =
            () -> {
              assertThat(Thread.currentThread().getName()).isEqualTo(newName.get());
              return null;
            };
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 4K bytes
    - Click Count (0)
  10. guava-tests/test/com/google/common/util/concurrent/CallablesTest.java

      }
    
      @J2ktIncompatible
      @GwtIncompatible // threads
      public void testRenaming() throws Exception {
        String oldName = Thread.currentThread().getName();
        Supplier<String> newName = Suppliers.ofInstance("MyCrazyThreadName");
        Callable<@Nullable Void> callable =
            () -> {
              assertThat(Thread.currentThread().getName()).isEqualTo(newName.get());
              return null;
            };
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 4K bytes
    - Click Count (0)
Back to Top