Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for numThreads (0.07 sec)

  1. src/main/java/jcifs/smb1/smb1/TestLocking.java

                }
            }
    
            final Thread[] threads = new Thread[t.numThreads];
            int ti;
    
            for (ti = 0; ti < t.numThreads; ti++) {
                threads[ti] = new Thread(t);
                logger.info(threads[ti].getName());
                threads[ti].start();
            }
    
            while (t.numComplete < t.numThreads) {
                long delay;
    
                do {
                    delay = 2L;
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 4.2K bytes
    - Viewed (0)
  2. src/test/java/jcifs/smb1/smb1/TestLockingTest.java

            // Set different values
            t1.numThreads = 2;
            t1.url = "smb://server1/share/file.txt";
    
            t2.numThreads = 5;
            t2.url = "smb://server2/share/file.txt";
    
            // Verify independence
            assertEquals(2, t1.numThreads, "t1 should have its own numThreads value");
            assertEquals(5, t2.numThreads, "t2 should have its own numThreads value");
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 9.9K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/hash/BloomFilterTest.java

        List<Throwable> exceptions = runThreadsAndReturnExceptions(numThreads, task);
    
        assertThat(exceptions).isEmpty();
      }
    
      private static List<Throwable> runThreadsAndReturnExceptions(int numThreads, Runnable task) {
        List<Thread> threads = new ArrayList<>(numThreads);
        List<Throwable> exceptions = new ArrayList<>(numThreads);
        for (int i = 0; i < numThreads; i++) {
          Thread thread = new Thread(task);
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 22K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/hash/BloomFilterTest.java

        List<Throwable> exceptions = runThreadsAndReturnExceptions(numThreads, task);
    
        assertThat(exceptions).isEmpty();
      }
    
      private static List<Throwable> runThreadsAndReturnExceptions(int numThreads, Runnable task) {
        List<Thread> threads = new ArrayList<>(numThreads);
        List<Throwable> exceptions = new ArrayList<>(numThreads);
        for (int i = 0; i < numThreads; i++) {
          Thread thread = new Thread(task);
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 22K bytes
    - Viewed (0)
  5. src/test/java/jcifs/util/AuthenticationRateLimiterTest.java

                    Duration.ofSeconds(2), Duration.ofMinutes(1));
    
            try {
                final int numThreads = 10;
                final int attemptsPerThread = 5;
    
                Thread[] threads = new Thread[numThreads];
                final AtomicInteger successfulThreads = new AtomicInteger(0);
                final AtomicInteger blockedAttempts = new AtomicInteger(0);
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 15.8K bytes
    - Viewed (0)
  6. src/test/java/jcifs/internal/smb1/com/SmbComTreeDisconnectTest.java

            // Given
            smbComTreeDisconnect = new SmbComTreeDisconnect(config);
            byte[] buffer = new byte[1000];
            int numThreads = 10;
            Thread[] threads = new Thread[numThreads];
    
            // When - multiple threads calling methods simultaneously
            for (int i = 0; i < numThreads; i++) {
                final int threadIndex = i;
                threads[i] = new Thread(() -> {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 18.5K bytes
    - Viewed (0)
Back to top