- Sort Score
- Result 10 results
- Languages All
Results 141 - 150 of 228 for ShutDown (0.06 sec)
-
build-logic/cleanup/src/main/java/gradlebuild/cleanup/services/KillLeakingJavaProcesses.java
pkill(pid); }); } else { forEachLeakingJavaProcess(rootProjectDir, (pid, line) -> { System.out.println("A process wasn't shutdown properly in a previous Gradle run. Killing process with PID " + pid + ": " + line); pkill(pid); }); } } private static void initExecutionMode(String[] args) {
Registered: Wed Nov 06 11:36:14 UTC 2024 - Last Modified: Mon Aug 19 15:07:24 UTC 2024 - 11.6K bytes - Viewed (0) -
cmd/server-main.go
Usage: "bind to a specific ADDRESS:PORT for embedded Console UI, ADDRESS can be an IP or hostname", EnvVar: "MINIO_CONSOLE_ADDRESS", }, cli.DurationFlag{ Name: "shutdown-timeout", Value: time.Second * 30, Usage: "shutdown timeout to gracefully shutdown server (DEPRECATED)", EnvVar: "MINIO_SHUTDOWN_TIMEOUT", Hidden: true, }, cli.DurationFlag{ Name: "idle-timeout", Value: xhttp.DefaultIdleTimeout,
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Sep 24 21:50:11 UTC 2024 - 35.2K bytes - Viewed (1) -
guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java
barrier.await(1, SECONDS); executor.execute(barrierTask); // timeout means the second task wasn't even tried barrier.await(1, SECONDS); } finally { service.shutdown(); } } public void testRejectedExecutionThrownWithMultipleCalls() throws Exception { final CountDownLatch latch = new CountDownLatch(1); final SettableFuture<?> future = SettableFuture.create();
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 11.4K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/CrawlerThread.java
crawlerContext.activeThreadCount--; } } protected boolean isContinue(final int tcCount) { if (!crawlerContainer.available()) { // system shutdown return false; } boolean isContinue = false; if (tcCount < crawlerContext.maxThreadCheckCount) { final long maxAccessCount = crawlerContext.getMaxAccessCount();
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Sat Oct 12 01:41:37 UTC 2024 - 15.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/Suggester.java
} public RefreshResponse refresh() { return client.admin().indices().prepareRefresh().execute().actionGet(suggestSettings.getIndexTimeout()); } public void shutdown() { threadPool.shutdownNow(); } public boolean createIndexIfNothing() { try { boolean created = false; final IndicesExistsResponse response =
Registered: Fri Nov 08 09:08:12 UTC 2024 - Last Modified: Sat Oct 12 00:10:39 UTC 2024 - 14.6K bytes - Viewed (0) -
docs/fa/docs/features.md
* پشتیبانی از **WebSocket**. * <abbr title="In-process background tasks">تسک های درجریان در پس زمینه</abbr>. * <abbr title="Startup and shutdown events">رویداد های راه اندازی و متوفق شدن<abbr>. * تست کلاینت ساخته شده به روی HTTPX. * **CORS**, GZip, فایل های استاتیک, <abbr title="Streaming responses">پاسخ های جریانی</abbr>. * پشتیبانی از **نشست ها و کوکی ها**.
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Tue Aug 06 04:48:30 UTC 2024 - 15K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/KotlinSourceModernTest.kt
object : okhttp3.mockwebserver.Dispatcher() { override fun dispatch(request: RecordedRequest): MockResponse = TODO() override fun peek(): MockResponse = TODO() override fun shutdown() = TODO() } } @Test fun dns() { var dns: Dns = Dns { TODO() } val system: Dns = Dns.SYSTEM } @Test fun eventListener() { val eventListener =
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Apr 01 14:21:25 UTC 2024 - 46.5K bytes - Viewed (0) -
cmd/erasure-sets.go
} return storageInfo } // Shutdown shutsdown all erasure coded sets in parallel // returns error upon first error. func (s *erasureSets) Shutdown(ctx context.Context) error { g := errgroup.WithNErrs(len(s.sets)) for index := range s.sets { index := index g.Go(func() error { return s.sets[index].Shutdown(ctx) }, index) } for _, err := range g.Wait() {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 27 10:41:37 UTC 2024 - 37K bytes - Viewed (1) -
guava-tests/test/com/google/common/collect/QueuesTest.java
private ExecutorService threadPool; @Override public void setUp() { threadPool = newCachedThreadPool(); } @Override public void tearDown() throws InterruptedException { threadPool.shutdown(); assertTrue("Some worker didn't finish in time", threadPool.awaitTermination(10, SECONDS)); } private static <T> int drain( BlockingQueue<T> q, Collection<? super T> buffer,
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 17 02:42:09 UTC 2024 - 12.1K bytes - Viewed (0) -
cmd/test-utils_test.go
} // Deleting the temporary backend and stopping the server. func (testServer TestServer) Stop() { testServer.cancel() testServer.Server.Close() testServer.Obj.Shutdown(context.Background()) os.RemoveAll(testServer.Root) for _, ep := range testServer.Disks { for _, disk := range ep.Endpoints { os.RemoveAll(disk.Path) } } }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 01 22:13:18 UTC 2024 - 77K bytes - Viewed (0)