Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 223 for nThreads (0.72 sec)

  1. 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();
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 19.7K bytes
    - Viewed (0)
  2. src/test/java/jcifs/internal/smb2/multichannel/ChannelFailoverTest.java

            // Simulate concurrent failures
            Thread[] threads = new Thread[5];
            for (int i = 0; i < threads.length; i++) {
                threads[i] = new Thread(() -> failover.handleFailure(failedChannel, error));
                threads[i].start();
            }
    
            // Wait for all threads to complete
            for (Thread thread : threads) {
                thread.join(1000);
            }
    
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 21 11:13:46 UTC 2025
    - 7.7K bytes
    - Viewed (0)
  3. src/test/java/jcifs/internal/smb1/trans2/Trans2SetFileInformationResponseTest.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);
            }
        }
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 15.9K bytes
    - Viewed (0)
  4. 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();
                }
    
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 17.5K bytes
    - Viewed (0)
  5. src/test/java/jcifs/context/BaseContextTest.java

            final int threadCount = 10;
            final Thread[] threads = new Thread[threadCount];
            final boolean[] results = new boolean[threadCount];
    
            // When
            for (int i = 0; i < threadCount; i++) {
                final int index = i;
                threads[i] = new Thread(() -> {
                    try {
                        // Multiple threads accessing context simultaneously
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 07:14:38 UTC 2025
    - 15.1K bytes
    - Viewed (0)
  6. src/test/java/jcifs/internal/smb2/multichannel/ChannelManagerTest.java

            // Test thread safety
            Thread[] threads = new Thread[10];
            for (int i = 0; i < threads.length; i++) {
                threads[i] = new Thread(() -> {
                    channelManager.getChannels();
                    channelManager.getHealthyChannels();
                    channelManager.getLoadBalancer();
                });
                threads[i].start();
            }
    
            for (Thread thread : threads) {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 21 11:13:46 UTC 2025
    - 7.6K bytes
    - Viewed (0)
  7. src/test/java/jcifs/EmptyIteratorTest.java

                            }
                        }
                        results[index] = true; // Mark as successful
                    });
                    threads[i].start();
                }
    
                // Wait for all threads to complete
                for (Thread thread : threads) {
                    thread.join();
                }
            }
    
            // Then
            for (int i = 0; i < threadCount; i++) {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 12K bytes
    - Viewed (0)
  8. src/test/java/jcifs/internal/smb1/trans/TransPeekNamedPipeTest.java

            Thread[] threads = new Thread[10];
    
            // Act
            for (int i = 0; i < threads.length; i++) {
                final int index = i;
                threads[i] = new Thread(() -> {
                    results[index] = transPeekNamedPipe.toString();
                });
                threads[i].start();
            }
    
            for (Thread thread : threads) {
                thread.join();
            }
    
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 12.4K bytes
    - Viewed (0)
  9. fess-crawler/src/test/java/org/codelibs/fess/net/protocol/gcs/HandlerTest.java

                    }
                }).start();
            }
    
            // Signal all threads to start at once
            startLatch.countDown();
    
            // Wait for all threads to complete
            assertTrue("Threads did not complete in time", doneLatch.await(5, TimeUnit.SECONDS));
    
            // All threads should fail with the same IOException (project ID is blank)
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Dec 11 08:38:29 UTC 2025
    - 14.1K bytes
    - Viewed (0)
  10. src/test/java/jcifs/internal/smb2/lock/Smb2LockResponseTest.java

                // Given
                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 {
                            byte[] buffer = new byte[10];
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 17.1K bytes
    - Viewed (0)
Back to top