- Sort Score
- Result 10 results
- Languages All
Results 311 - 320 of 689 for executor (0.04 sec)
-
api/maven-api-spi/src/main/java/org/apache/maven/api/spi/LifecycleProvider.java
* This interface allows plugins and extensions to define and register additional build lifecycles * beyond the standard ones provided by Maven (like clean, default, site). Lifecycles define a sequence * of phases that can be executed during a build. * <p> * Implementations of this interface will be discovered through the Java ServiceLoader mechanism * and their provided lifecycles will be available throughout the Maven build process. * <p>
Registered: Sun Sep 07 03:35:12 UTC 2025 - Last Modified: Thu Apr 03 13:33:59 UTC 2025 - 2.2K bytes - Viewed (0) -
src/main/java/jcifs/util/SimpleCircuitBreaker.java
throw new IllegalArgumentException("Timeout must be non-negative"); } } /** * Execute a callable through the circuit breaker * * @param <T> return type * @param callable the callable to execute * @return the result * @throws Exception if execution fails or circuit is open */ public <T> T call(Callable<T> callable) throws Exception {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 11.3K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/CacheTest.kt
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 16 09:39:51 UTC 2025 - 113.6K bytes - Viewed (0) -
src/main/java/jcifs/smb1/dcerpc/DcerpcConstants.java
*/ int DCERPC_RESERVED_1 = 0x08; /** * Supports concurrent multiplexing flag */ int DCERPC_CONC_MPX = 0x10; /* supports concurrent multiplexing */ /** * Did not execute flag - indicates request was not executed */ int DCERPC_DID_NOT_EXECUTE = 0x20; /** * Maybe flag - indicates 'maybe' call semantics requested */ int DCERPC_MAYBE = 0x40; /* `maybe' call semantics requested */
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 2.2K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/internal/TriggerSink.kt
* See the License for the specific language governing permissions and * limitations under the License. * */ package mockwebserver3.internal import okio.Buffer import okio.Sink /** * A sink that executes [trigger] after [triggerByteCount] bytes are written, and then skips all * subsequent bytes. */ internal class TriggerSink( private val delegate: Sink, private val triggerByteCount: Long,
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 1.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ThreadFactoryBuilderTest.java
* limitations under the License. */ package com.google.common.util.concurrent; import static com.google.common.truth.Truth.assertThat; import static java.util.concurrent.Executors.defaultThreadFactory; import static org.junit.Assert.assertThrows; import com.google.common.testing.NullPointerTester; import java.lang.Thread.UncaughtExceptionHandler; import java.util.Locale;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 7.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ThreadFactoryBuilderTest.java
* limitations under the License. */ package com.google.common.util.concurrent; import static com.google.common.truth.Truth.assertThat; import static java.util.concurrent.Executors.defaultThreadFactory; import static org.junit.Assert.assertThrows; import com.google.common.testing.NullPointerTester; import java.lang.Thread.UncaughtExceptionHandler; import java.util.Locale;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 7.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/WrappingScheduledExecutorServiceTest.java
* the License. */ package com.google.common.util.concurrent; import static com.google.common.truth.Truth.assertThat; import static java.util.concurrent.Executors.callable; import static java.util.concurrent.TimeUnit.MINUTES; import static java.util.concurrent.TimeUnit.SECONDS; import java.util.Collection; import java.util.List; import java.util.concurrent.Callable;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Jul 14 14:44:08 UTC 2025 - 7.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/job/GenerateThumbnailJob.java
import org.codelibs.fess.util.ResourceUtil; import org.codelibs.fess.util.SystemUtil; import jakarta.servlet.ServletContext; /** * Job class for generating thumbnails for documents in the search engine. * This job executes the ThumbnailGenerator process as a separate JVM process * to create thumbnail images for supported document types. */ public class GenerateThumbnailJob extends ExecJob { /** Logger for this class. */
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 11.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/TimeLimiter.java
* * @param callable the Callable to execute * @param timeoutDuration with timeoutUnit, the maximum length of time to wait * @param timeoutUnit with timeoutDuration, the maximum length of time to wait * @return the result returned by the Callable * @throws TimeoutException if the time limit is reached * @throws InterruptedException if the current thread was interrupted during execution
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Jan 18 02:54:30 UTC 2025 - 8.2K bytes - Viewed (0)