Search Options

Results per page
Sort
Preferred Languages
Advance

Results 311 - 320 of 689 for executor (0.04 sec)

  1. 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)
  2. 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)
  3. okhttp/src/jvmTest/kotlin/okhttp3/CacheTest.kt

        client.newCall(request).execute().use {
          it.body.bytes()
        }
        return client.newCall(request).execute()
      }
    
      private operator fun get(url: HttpUrl): Response {
        val request =
          Request
            .Builder()
            .url(url)
            .build()
        return client.newCall(request).execute()
      }
    
      private fun writeFile(
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 16 09:39:51 UTC 2025
    - 113.6K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top