- Sort Score
- Result 10 results
- Languages All
Results 651 - 660 of 932 for executeOn (1.93 sec)
-
android/guava/src/com/google/common/eventbus/Subscriber.java
method.setAccessible(true); this.executor = bus.executor(); } /** Dispatches {@code event} to this subscriber using the proper executor. */ final void dispatchEvent(Object event) { executor.execute( () -> { try { invokeSubscriberMethod(event); } catch (InvocationTargetException e) { bus.handleSubscriberException(e.getCause(), context(event)); }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed May 14 19:40:47 UTC 2025 - 4.7K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/mylasta/direction/sponsor/FessCurtainBeforeHookTest.java
DfFinalTimeZoneProvider provider = getDBFluteSystemTimeZoneProvider(); // Provider might be null due to reflection limitations, which is ok assertTrue("processDBFluteSystem executed without exception", true); } catch (Exception e) { fail("processDBFluteSystem should handle unlock/lock properly: " + e.getMessage()); } }
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 8.1K bytes - Viewed (0) -
compat/maven-compat/src/main/java/org/apache/maven/DefaultProjectDependenciesResolver.java
import org.apache.maven.artifact.resolver.ResolutionErrorHandler; import org.apache.maven.artifact.resolver.filter.CumulativeScopeArtifactFilter; import org.apache.maven.execution.MavenSession; import org.apache.maven.project.MavenProject; import org.apache.maven.project.artifact.ProjectArtifact; import org.apache.maven.repository.RepositorySystem; /**
Registered: Sun Sep 07 03:35:12 UTC 2025 - Last Modified: Fri Jun 06 14:28:57 UTC 2025 - 8.4K bytes - Viewed (0) -
guava-testlib/test/com/google/common/testing/GcFinalizationTest.java
@AndroidIncompatible // depends on details of gc @NullUnmarked public class GcFinalizationTest extends TestCase { // ---------------------------------------------------------------- // Ordinary tests of successful method execution // ---------------------------------------------------------------- public void testAwait_countDownLatch() { CountDownLatch latch = new CountDownLatch(1); Object unused = new Object() {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 18:46:00 UTC 2025 - 7.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AggregateFutureStateFallbackAtomicHelperTest.java
* AtomicIntegerFieldUpdater}, which will prevent us from selecting the {@code SafeAtomicHelper} * strategy. * * <p>Stashing this in a static field avoids loading it over and over again and speeds up test * execution significantly. */ private static final ClassLoader NO_ATOMIC_FIELD_UPDATER = getClassLoader( ImmutableSet.of( AtomicIntegerFieldUpdater.class.getName(),
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 18:46:00 UTC 2025 - 6.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/query/PhraseQueryCommand.java
@Override protected String getQueryClassName() { return PhraseQuery.class.getSimpleName(); } @Override public QueryBuilder execute(final QueryContext context, final Query query, final float boost) { if (query instanceof final PhraseQuery phraseQuery) { if (logger.isDebugEnabled()) { logger.debug("{}:{}", query, boost);
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 4.5K bytes - Viewed (0) -
docs/en/docs/tutorial/cookie-param-models.md
If you go to the **API docs UI** at `/docs` you will be able to see the **documentation** for cookies for your *path operations*. But even if you **fill the data** and click "Execute", because the docs UI works with **JavaScript**, the cookies won't be sent, and you will see an **error** message as if you didn't write any values. /// ## Forbid Extra Cookies { #forbid-extra-cookies }
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sun Aug 31 09:15:41 UTC 2025 - 3.1K bytes - Viewed (0) -
regression-test/src/androidTest/java/okhttp/regression/LetsEncryptTest.java
private void sendRequest(OkHttpClient client, String url) throws IOException { Request request = new Request.Builder() .url(url) .build(); try (Response response = client.newCall(request).execute()) { assertTrue(response.code() == 200 || response.code() == 404); assertEquals(Protocol.HTTP_2, response.protocol()); } }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue Nov 17 07:40:31 UTC 2020 - 6.1K bytes - Viewed (0) -
docs/features/calls.md
Calls are executed in one of two ways: * **Synchronous:** your thread blocks until the response is readable.
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sun Feb 06 02:19:09 UTC 2022 - 3.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/SystemHelper.java
protected String filterPathEncoding; /** An array of supported language codes. */ protected String[] supportedLanguages; /** A list of shutdown hooks to be executed on system shutdown. */ protected List<Runnable> shutdownHookList = new ArrayList<>(); /** The previous state of the cluster. */ protected AtomicInteger previousClusterState = new AtomicInteger(0);
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sun Aug 31 08:19:00 UTC 2025 - 36.6K bytes - Viewed (0)