- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 255 for shutDown (0.05 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
docs/en/docs/advanced/events.md
### `shutdown` event { #shutdown-event } To add a function that should be run when the application is shutting down, declare it with the event `"shutdown"`: {* ../../docs_src/events/tutorial002_py310.py hl[6] *} Here, the `shutdown` event handler function will write a text line `"Application shutdown"` to a file `log.txt`. /// infoCreated: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 05 18:13:19 GMT 2026 - 7.8K bytes - Click Count (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java
private volatile boolean shutdown; @Override public void shutdown() { shutdown = true; } @Override public List<Runnable> shutdownNow() { shutdown(); return ImmutableList.of(); } @Override public boolean isShutdown() { return shutdown; } @Override public boolean isTerminated() {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Jul 17 15:26:41 GMT 2025 - 6.6K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/job/JobExecutor.java
/** * Initiates shutdown of the job executor. * This method notifies the shutdown listener to perform cleanup operations. */ public void shutdown() { shutdownListener.onShutdown(); } /** * Adds a shutdown listener to be notified when the executor is shutting down. * * @param listener the shutdown listener to add */Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Jul 17 08:28:31 GMT 2025 - 2.1K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/WebSocket.kt
* message buffer (16 MiB) will be rejected and trigger a [graceful shutdown][close] of this web * socket. This method returns false in that case, and in any other case where this web socket is * closing, closed, or canceled. * * This method returns immediately. */ fun send(bytes: ByteString): Boolean /** * Attempts to initiate a graceful shutdown of this web socket. Any already-enqueued messages will
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Mar 10 21:45:14 GMT 2026 - 6.1K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/job/JobExecutorTest.java
assertEquals(listener, jobExecutor.shutdownListener); // Verify listener is called on shutdown jobExecutor.shutdown(); assertTrue(shutdownCalled.get()); } @Test public void test_addShutdownListener_replace() { // Test replacing shutdown listener AtomicInteger callCount = new AtomicInteger(0); ShutdownListener listener1 = new ShutdownListener() {
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Wed Jan 14 14:29:07 GMT 2026 - 9.4K bytes - Click Count (0) -
docs/ja/docs/advanced/testing-events.md
# イベントのテスト: lifespan と startup - shutdown { #testing-events-lifespan-and-startup-shutdown } テストで `lifespan` を実行する必要がある場合は、`with` 文と併用して `TestClient` を使用できます: {* ../../docs_src/app_testing/tutorial004_py310.py hl[9:15,18,27:28,30:32,41:43] *} より詳しい内容は、[公式 Starlette ドキュメントの「テストでの lifespan の実行」](https://www.starlette.dev/lifespan/#running-lifespan-in-tests) を参照してください。 非推奨の `startup` および `shutdown` イベントについては、次のように `TestClient` を使用できます:Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Fri Feb 13 15:24:30 GMT 2026 - 724 bytes - Click Count (0) -
internal/http/server.go
return srv.Serve(l) } return serve, err } // Shutdown - shuts down HTTP server. func (srv *Server) Shutdown() error { srv.listenerMutex.Lock() if srv.listener == nil { srv.listenerMutex.Unlock() return http.ErrServerClosed } srv.listenerMutex.Unlock() if atomic.AddUint32(&srv.inShutdown, 1) > 1 { // shutdown in progress return http.ErrServerClosed }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 6.5K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
* the "running" state need to perform a periodic task. Subclasses can implement {@link #startUp}, * {@link #shutDown} and also a {@link #runOneIteration} method that will be executed periodically. * * <p>This class uses the {@link ScheduledExecutorService} returned from {@link #executor} to run * the {@link #startUp} and {@link #shutDown} methods and also uses that service to schedule the
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Aug 09 01:14:59 GMT 2025 - 27.7K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
ExecutorService service = mock(ExecutorService.class); application.addDelayedShutdownHook(service, 2, SECONDS); verify(service, never()).shutdown(); application.shutdown(); InOrder shutdownFirst = inOrder(service); shutdownFirst.verify(service).shutdown(); shutdownFirst.verify(service).awaitTermination(2, SECONDS); }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 26.1K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskQueue.kt
task: Task, delayNanos: Long = 0L, ) { taskRunner.withLock { if (shutdown) { if (task.cancelable) { taskRunner.logger.taskLog(task, this) { "schedule canceled (queue is shutdown)" } return } taskRunner.logger.taskLog(task, this) { "schedule failed (queue is shutdown)" } throw RejectedExecutionException() }Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed May 28 23:28:25 GMT 2025 - 7.3K bytes - Click Count (0)