Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 825 for Threads (0.19 sec)

  1. src/main/java/org/codelibs/fess/timer/SystemMonitorTarget.java

                return b.toString();
            }).collect(Collectors.joining(",")));
            buf.append("},");
            final Threads threads = jvmStats.getThreads();
            buf.append("\"threads\":{");
            append(buf, "count", () -> threads.getCount()).append(',');
            append(buf, "peak", () -> threads.getPeakCount());
            buf.append("},");
            final Classes classes = jvmStats.getClasses();
    Java
    - Registered: Mon May 06 08:04:11 GMT 2024
    - Last Modified: Thu Feb 22 01:37:57 GMT 2024
    - 7.5K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/CallablesTest.java

              public @Nullable Void call() throws Exception {
                assertEquals(Thread.currentThread().getName(), newName.get());
                return null;
              }
            };
        Callables.threadRenaming(callable, newName).call();
        assertEquals(oldName, Thread.currentThread().getName());
      }
    
      @J2ktIncompatible
      @GwtIncompatible // threads
      public void testRenaming_exceptionalReturn() throws Exception {
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 5.4K bytes
    - Viewed (0)
  3. src/cmd/cgo/internal/test/issue18146.go

    		var rlim syscall.Rlimit
    		if syscall.Getrlimit(nproc, &rlim) == nil {
    			max := int(rlim.Cur) / (threads + 5)
    			if attempts > max {
    				t.Logf("lowering attempts from %d to %d for RLIMIT_NPROC", attempts, max)
    				attempts = max
    			}
    		}
    	}
    
    	if os.Getenv("test18146") == "exec" {
    		runtime.GOMAXPROCS(1)
    		for n := threads; n > 0; n-- {
    			go func() {
    				for {
    					_ = md5.Sum([]byte("Hello, !"))
    				}
    			}()
    Go
    - Registered: Tue Apr 23 11:13:09 GMT 2024
    - Last Modified: Tue Sep 05 23:35:32 GMT 2023
    - 2.8K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/TestThread.java

        start();
      }
    
      // Thread.stop() is okay because all threads started by a test are dying at the end of the test,
      // so there is no object state put at risk by stopping the threads abruptly. In some cases a test
      // may put a thread into an uninterruptible operation intentionally, so there is no other way to
      // clean up these threads.
      @SuppressWarnings("deprecation")
      @Override
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Apr 26 20:07:17 GMT 2023
    - 10.9K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

      /** Checks that the threads do not terminate within the given millisecond delay. */
      void assertThreadsStayAlive(long millis, Thread... threads) {
        try {
          // No need to optimize the failing case via Thread.join.
          delay(millis);
          for (Thread thread : threads) assertTrue(thread.isAlive());
        } catch (InterruptedException ie) {
          fail("Unexpected InterruptedException");
        }
      }
    
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Feb 22 17:15:24 GMT 2024
    - 37.2K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/AtomicLongMapBasherTest.java

    /**
     * Basher test for {@link AtomicLongMap}.
     *
     * @author mike nonemacher
     */
    @J2ktIncompatible // threads
    @GwtIncompatible // threads
    public class AtomicLongMapBasherTest extends TestCase {
      private final Random random = new Random(301);
    
      public void testModify_basher() throws Exception {
        int nTasks = 3000;
        int nThreads = 100;
        final int getsPerTask = 1000;
        final int deltaRange = 10000;
        final String key = "key";
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 4.2K bytes
    - Viewed (0)
  7. maven-compat/src/main/java/org/apache/maven/artifact/resolver/DefaultArtifactResolver.java

        private final Executor executor;
    
        public DefaultArtifactResolver() {
            int threads = Integer.getInteger("maven.artifact.threads", 5);
            if (threads <= 1) {
                executor = Runnable::run;
            } else {
                executor = new ThreadPoolExecutor(
                        threads, threads, 3, TimeUnit.SECONDS, new LinkedBlockingQueue<>(), new DaemonThreadCreator());
            }
        }
    
    Java
    - Registered: Sun May 05 03:35:11 GMT 2024
    - Last Modified: Thu Apr 25 05:46:50 GMT 2024
    - 24.8K bytes
    - Viewed (0)
  8. okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt

     * deterministic.
     *
     * This class ensures that at most one thread is running at a time. This is initially the JUnit test
     * thread, which yields its execution privilege while calling [runTasks], [runNextTask], or
     * [advanceUntil]. These functions don't return until the task threads are all idle.
     *
     * Task threads release their execution privilege in these ways:
     *
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 29 00:33:04 GMT 2024
    - 12.6K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/collect/ConcurrentHashMultisetBasherTest.java

    import java.util.concurrent.atomic.AtomicInteger;
    import junit.framework.TestCase;
    
    /**
     * Basher test for {@link ConcurrentHashMultiset}: start a bunch of threads, have each of them do
     * operations at random. Each thread keeps track of the per-key deltas that it's directly
     * responsible for; after all threads have completed, we sum the per-key deltas and compare to the
     * existing multiset values.
     *
     * @author mike nonemacher
     */
    
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Mon Dec 04 17:37:03 GMT 2017
    - 5.8K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/collect/ConcurrentHashMultisetBasherTest.java

    import java.util.concurrent.atomic.AtomicInteger;
    import junit.framework.TestCase;
    
    /**
     * Basher test for {@link ConcurrentHashMultiset}: start a bunch of threads, have each of them do
     * operations at random. Each thread keeps track of the per-key deltas that it's directly
     * responsible for; after all threads have completed, we sum the per-key deltas and compare to the
     * existing multiset values.
     *
     * @author mike nonemacher
     */
    
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Mon Dec 04 17:37:03 GMT 2017
    - 5.8K bytes
    - Viewed (0)
Back to top