Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for activeCount (0.06 sec)

  1. compat/maven-compat/src/test/java/org/apache/maven/artifact/resolver/DefaultArtifactResolverTest.java

                    continue;
                }
    
                seen = true;
    
                tg = aTgList;
                Thread[] ts = new Thread[tg.activeCount()];
                tg.enumerate(ts);
    
                for (Thread active : ts) {
                    String name = active.getName();
                    boolean daemon = active.isDaemon();
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 3K bytes
    - Viewed (0)
  2. android/guava-testlib/src/com/google/common/testing/GcFinalization.java

        //
        // TODO(user): Consider using
        // java/lang/management/OperatingSystemMXBean.html#getSystemLoadAverage()
        //
        // TODO(user): Consider scaling by number of mutator threads,
        // e.g. using Thread#activeCount()
        return max(10L, Runtime.getRuntime().totalMemory() / (32L * 1024L * 1024L));
      }
    
      /**
       * Waits until the given future {@linkplain Future#isDone is done}, invoking the garbage collector
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  3. guava-testlib/src/com/google/common/testing/GcFinalization.java

        //
        // TODO(user): Consider using
        // java/lang/management/OperatingSystemMXBean.html#getSystemLoadAverage()
        //
        // TODO(user): Consider scaling by number of mutator threads,
        // e.g. using Thread#activeCount()
        return max(10L, Runtime.getRuntime().totalMemory() / (32L * 1024L * 1024L));
      }
    
      /**
       * Waits until the given future {@linkplain Future#isDone is done}, invoking the garbage collector
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt

            maxIdleConnections = 2,
          )
        factory.newConnection(pool, routeA1)
        assertThat(realTaskRunner.activeQueues()).isNotEmpty()
        Thread.sleep(100)
        val threads = arrayOfNulls<Thread>(Thread.activeCount() * 2)
        Thread.enumerate(threads)
        for (t in threads) {
          if (t != null && t.name == "OkHttp TaskRunner") {
            t.interrupt()
          }
        }
        Thread.sleep(100)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jun 22 16:06:35 UTC 2024
    - 12.8K bytes
    - Viewed (0)
Back to top