- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 212 for StateT (0.08 sec)
-
android/guava/src/com/google/common/util/concurrent/Service.java
boolean isRunning(); /** Returns the lifecycle state of the service. */ State state(); /** * If the service is {@linkplain State#STARTING starting} or {@linkplain State#RUNNING running}, * this initiates service shutdown and returns immediately. If the service is {@linkplain * State#NEW new}, it is {@linkplain State#TERMINATED terminated} without having been started nor
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 10.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ServiceManager.java
@Override public void running() { ServiceManagerState state = this.state.get(); if (state != null) { state.transitionService(service, STARTING, RUNNING); } } @Override public void stopping(State from) { ServiceManagerState state = this.state.get(); if (state != null) { state.transitionService(service, from, STOPPING); } }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:51:36 UTC 2024 - 33.5K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ServiceManager.java
@Override public void running() { ServiceManagerState state = this.state.get(); if (state != null) { state.transitionService(service, STARTING, RUNNING); } } @Override public void stopping(State from) { ServiceManagerState state = this.state.get(); if (state != null) { state.transitionService(service, from, STOPPING); } }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:51:36 UTC 2024 - 33.2K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Service.java
boolean isRunning(); /** Returns the lifecycle state of the service. */ State state(); /** * If the service is {@linkplain State#STARTING starting} or {@linkplain State#RUNNING running}, * this initiates service shutdown and returns immediately. If the service is {@linkplain * State#NEW new}, it is {@linkplain State#TERMINATED terminated} without having been started nor
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 12.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/sso/aad/AzureAdAuthenticator.java
@SuppressWarnings("unchecked") final Map<String, StateData> states = (Map<String, StateData>) session.getAttribute(STATES); if (states != null) { final long now = ComponentUtil.getSystemHelper().getCurrentTimeAsLong(); states.entrySet().stream().filter(e -> (now - e.getValue().getExpiration()) / 1000L > getStateTtl()).map(Map.Entry::getKey)
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 28.2K bytes - Viewed (0) -
apache-maven/src/main/appended-resources/licenses/EPL-1.0.txt
including direct, indirect, special, incidental and consequential damages, such as lost profits; iii) states that any provisions which differ from this Agreement are offered by that Contributor alone and not by any other party; and iv) states that source code for the Program is available from such Contributor, and informs licensees how to obtain it in a reasonable manner on or through
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Mon Sep 17 05:50:12 UTC 2018 - 11.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
static void awaitWaiting(Thread t) { while (true) { Thread.State state = t.getState(); switch (state) { case RUNNABLE: case BLOCKED: Thread.yield(); break; case WAITING: return; default: throw new AssertionError("unexpected state: " + state); } } }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 17 02:42:09 UTC 2024 - 13.6K bytes - Viewed (0) -
docs/bucket/replication/DESIGN.md
the source object version, such as metadata updates via PutObjectTagging, PutObjectRetention, PutObjectLegalHold and COPY api are replicated in a similar manner to target version, with the `X-Amz-Replication-Status` again cycling through the same states. The description above details one way replication from source to target w.r.t incoming object uploads and metadata changes to source object version. If active-active replication is configured, any incoming uploads and metadata changes to...
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 29 04:28:45 UTC 2022 - 14.7K bytes - Viewed (0) -
cmd/admin-heal-ops.go
} // LaunchNewHealSequence - launches a background routine that performs // healing according to the healSequence argument. For each heal // sequence, state is stored in the `globalAllHealState`, which is a // map of the heal path to `healSequence` which holds state about the // heal sequence. // // Heal results are persisted in server memory for // `keepHealSeqStateDuration`. This function also launches a
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Oct 26 09:58:27 UTC 2024 - 25.6K bytes - Viewed (0) -
LICENSES/vendor/github.com/containerd/containerd/api/LICENSE
for any such Derivative Works as a whole, provided Your use, reproduction, and distribution of the Work otherwise complies with the conditions stated in this License. 5. Submission of Contributions. Unless You explicitly state otherwise, any Contribution intentionally submitted for inclusion in the Work by You to the Licensor shall be under the terms and conditions of
Registered: Fri Nov 01 09:05:11 UTC 2024 - Last Modified: Sun Sep 22 18:50:45 UTC 2024 - 10.7K bytes - Viewed (0)