- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 26 for pools (0.15 sec)
-
android/guava/src/com/google/common/util/concurrent/MoreExecutors.java
* is complete. It does so by using daemon threads and adding a shutdown hook to wait for their * completion. * * <p>This is mainly for fixed thread pools. See {@link Executors#newFixedThreadPool(int)}. * * @param executor the executor to modify to make sure it exits when the application is finished
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Apr 17 16:33:44 GMT 2024 - 41.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/stats/ApiAdminStatsAction.java
jvmMemoryNonHeapObj.used = mem.getNonHeapUsed().getBytes(); jvmMemoryNonHeapObj.committed = mem.getNonHeapCommitted().getBytes(); final List<BufferPool> bufferPools = jvmStats.getBufferPools(); jvmObj.pools = bufferPools.stream().map(p -> { final JvmPoolObj jvmPoolObj = new JvmPoolObj(); jvmPoolObj.key = p.getName(); jvmPoolObj.count = p.getCount();
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 12.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/timer/SystemMonitorTarget.java
append(buf, "committed", () -> mem.getNonHeapCommitted().getBytes()); buf.append('}'); buf.append("},"); final List<BufferPool> bufferPools = jvmStats.getBufferPools(); buf.append("\"pools\":{"); buf.append(bufferPools.stream().map(p -> { final StringBuilder b = new StringBuilder(); b.append('"').append(StringEscapeUtils.escapeJson(p.getName())).append("\":{");
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) -
android/guava-tests/test/com/google/common/graph/NetworkMutationTest.java
@RunWith(JUnit4.class) public final class NetworkMutationTest { private static final int NUM_TRIALS = 5; private static final int NUM_NODES = 20; private static final int NUM_EDGES = 100; private static final int NODE_POOL_SIZE = 1000; // must be >> NUM_NODES @Test public void directedNetwork() { testNetworkMutation(NetworkBuilder.directed()); } @Test public void undirectedNetwork() {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Apr 10 19:42:18 GMT 2024 - 4.5K bytes - Viewed (0) -
android/guava/src/com/google/common/net/InetAddresses.java
* Returns the string representation of an {@link InetAddress}. * * <p>For IPv4 addresses, this is identical to {@link InetAddress#getHostAddress()}, but for IPv6 * addresses, the output follows <a href="http://tools.ietf.org/html/rfc5952">RFC 5952</a> section * 4. The main difference is that this method uses "::" for zero compression, while Java's version * uses the uncompressed form. *
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri Dec 15 19:31:54 GMT 2023 - 44K bytes - Viewed (1) -
src/test/java/org/codelibs/fess/it/search/SearchApiTests.java
private static final String DEFAULT_TESTDATA_PATH = "/tmp/fess-testdata"; private static final String CRAWL_LABEL = NAME_PREFIX + "_label"; private static final String TEST_LABEL = "tools"; private static String fileConfigId; private static String labelId; private static String crawlLabelId; @BeforeAll protected static void initAll() { RestAssured.baseURI = getFessUrl();
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 18.6K bytes - Viewed (1) -
src/main/java/org/codelibs/fess/mylasta/direction/FessConfig.java
/** The key of the configuration. e.g. groovy */ String CRAWLER_DEFAULT_SCRIPT = "crawler.default.script"; /** The key of the configuration. e.g. 0 */ String CRAWLER_HTTP_thread_pool_SIZE = "crawler.http.thread_pool.size"; /** The key of the configuration. e.g. 100 */ String CRAWLER_DOCUMENT_MAX_SITE_LENGTH = "crawler.document.max.site.length"; /** The key of the configuration. e.g. UTF-8 */
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Apr 11 02:34:53 GMT 2024 - 459.2K bytes - Viewed (5) -
src/test/java/org/codelibs/fess/helper/CrawlingInfoHelperTest.java
final ForkJoinPool pool = new ForkJoinPool(10); for (int i = 0; i < 1000; i++) { pool.execute(() -> { assertEquals(result, crawlingInfoHelper.generateId(dataMap)); counter.incrementAndGet(); }); } pool.shutdown(); pool.awaitTermination(10, TimeUnit.SECONDS);
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 8.5K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/project/ProjectModelResolver.java
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Thu Apr 25 14:13:36 GMT 2024 - 15.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
Thread.yield(); long d = ns - (System.nanoTime() - startTime); if (d > 0L) millis = d / (1000 * 1000); else break; } } /** Waits out termination of a thread pool or fails doing so. */ void joinPool(ExecutorService exec) { try { exec.shutdown(); assertTrue( "ExecutorService did not terminate in a timely manner",
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Thu Feb 22 17:15:24 GMT 2024 - 37.7K bytes - Viewed (0)