- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 274 for isShutdown (0.17 sec)
-
guava/src/com/google/common/util/concurrent/MoreExecutors.java
} @Override public final boolean isShutdown() { return delegate.isShutdown(); } @Override public final boolean isTerminated() { return delegate.isTerminated(); } @Override public final void shutdown() { delegate.shutdown(); } @Override public final List<Runnable> shutdownNow() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 15 10:40:05 UTC 2024 - 43.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/MoreExecutors.java
} @Override public final boolean isShutdown() { return delegate.isShutdown(); } @Override public final boolean isTerminated() { return delegate.isTerminated(); } @Override public final void shutdown() { delegate.shutdown(); } @Override public final List<Runnable> shutdownNow() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 15 10:40:05 UTC 2024 - 39K bytes - Viewed (0) -
testing/internal-testing/src/main/groovy/org/gradle/test/fixtures/ConcurrentTestUtil.groovy
void execute(Runnable runnable) { threads.add(owner.startThread(runnable)) } void shutdown() { throw new UnsupportedOperationException() } List<Runnable> shutdownNow() { throw new UnsupportedOperationException() } boolean isShutdown() { throw new UnsupportedOperationException() } boolean isTerminated() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 22.9K bytes - Viewed (0) -
android/guava-testlib/test/com/google/common/testing/GcFinalizationTest.java
} } }); this.shutdown = shutdown; start(); } void shutdown() { shutdown.set(true); while (this.isAlive()) { Thread.yield(); } } } void assertWrapsInterruptedException(RuntimeException e) { assertThat(e).hasMessageThat().contains("Unexpected interrupt");
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 10 19:21:11 UTC 2024 - 7.4K bytes - Viewed (0) -
docs/en/docs/advanced/events.md
### `shutdown` event To add a function that should be run when the application is shutting down, declare it with the event `"shutdown"`: ```Python hl_lines="6" {!../../../docs_src/events/tutorial002.py!} ``` Here, the `shutdown` event handler function will write a text line `"Application shutdown"` to a file `log.txt`. !!! info
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Thu Apr 18 19:53:19 UTC 2024 - 7.8K bytes - Viewed (0) -
pilot/pkg/xds/pushqueue_test.go
t.Parallel() p := NewPushQueue() defer p.ShutDown() p.Enqueue(proxies[0], &model.PushRequest{}) p.Enqueue(proxies[1], &model.PushRequest{}) ExpectDequeue(t, p, proxies[0]) ExpectDequeue(t, p, proxies[1]) }) t.Run("remove too many", func(t *testing.T) { t.Parallel() p := NewPushQueue() defer p.ShutDown() p.Enqueue(proxies[0], &model.PushRequest{})
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 8.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/genericapiserver.go
// ShutdownSendRetryAfter dictates when to initiate shutdown of the HTTP // Server during the graceful termination of the apiserver. If true, we wait // for non longrunning requests in flight to be drained and then initiate a // shutdown of the HTTP Server. If false, we initiate a shutdown of the HTTP // Server as soon as ShutdownDelayDuration has elapsed.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 42.9K bytes - Viewed (0) -
testing/smoke-test/src/smokeTest/resources/org/gradle/play/integtest/fixtures/external/basicplayapp/conf/routes.old
# Routes # Home page GET / controllers.Application.index GET /shutdown controllers.Application.shutdown # Map static resources from the /public folder to the /assets URL path
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 310 bytes - Viewed (0) -
docs/zh/docs/advanced/events.md
本例中,`startup` 事件处理器函数为项目数据库(只是**字典**)提供了一些初始值。 **FastAPI** 支持多个事件处理器函数。 只有所有 `startup` 事件处理器运行完毕,**FastAPI** 应用才开始接收请求。 ## `shutdown` 事件 使用 `shutdown` 事件声明 `app` 关闭时运行的函数: ```Python hl_lines="6" {!../../../docs_src/events/tutorial002.py!} ``` 此处,`shutdown` 事件处理器函数在 `log.txt` 中写入一行文本 `Application shutdown`。 !!! info "说明" `open()` 函数中,`mode="a"` 指的是**追加**。因此这行文本会添加在文件已有内容之后,不会覆盖之前的内容。 !!! tip "提示"
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Thu Apr 18 19:53:19 UTC 2024 - 1.7K bytes - Viewed (0) -
internal/event/target/nats_contrib_test.go
natsserver "github.com/nats-io/nats-server/v2/test" ) func TestNatsConnPlain(t *testing.T) { opts := natsserver.DefaultTestOptions opts.Port = 14222 s := natsserver.RunServer(&opts) defer s.Shutdown() clientConfig := &NATSArgs{ Enable: true, Address: xnet.Host{ Name: "localhost", Port: (xnet.Port(opts.Port)), IsPortSet: true, }, Subject: "test", }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 2.3K bytes - Viewed (0)