- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 1,348 for executors (0.17 sec)
-
guava/src/com/google/common/util/concurrent/SimpleTimeLimiter.java
public final class SimpleTimeLimiter implements TimeLimiter { private final ExecutorService executor; private SimpleTimeLimiter(ExecutorService executor) { this.executor = checkNotNull(executor); } /** * Creates a TimeLimiter instance using the given executor service to execute method calls. * * <p><b>Warning:</b> using a bounded executor may be counterproductive! If the thread pool fills
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 27 14:21:11 UTC 2023 - 9.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ThreadFactoryBuilderTest.java
import static org.junit.Assert.assertThrows; import com.google.common.testing.NullPointerTester; import java.lang.Thread.UncaughtExceptionHandler; import java.util.Locale; import java.util.concurrent.Executors; import java.util.concurrent.ThreadFactory; import junit.framework.TestCase; /** * Tests for ThreadFactoryBuilder. * * @author Kurt Alfred Kluever * @author Martin Buchholz */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 7.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/exec/ThumbnailGenerator.java
*/ package org.codelibs.fess.exec; import java.io.File; import java.lang.management.ManagementFactory; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.TimeUnit; import javax.annotation.Resource; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.core.lang.StringUtil;
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 8.2K bytes - Viewed (0) -
.github/workflows/CheckBadMerge.groovy
* See the License for the specific language governing permissions and * limitations under the License. */ import java.util.concurrent.Callable import java.util.concurrent.Executors import java.util.concurrent.Future /** * See https://github.com/gradle/gradle-private/issues/3919 * * When merging `releaseX` branch into `master`, we should only use the release note from the `master` branch,
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Dec 19 10:35:44 UTC 2023 - 6.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ClosingFutureFinishToValueAndCloserTest.java
import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutionException; import java.util.concurrent.Executor; import java.util.concurrent.ExecutorService; /** * Tests for {@link ClosingFuture} that exercise {@link * ClosingFuture#finishToValueAndCloser(ValueAndCloserConsumer, Executor)}. */ public class ClosingFutureFinishToValueAndCloserTest extends AbstractClosingFutureTest {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 5.7K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/operations/BuildOperationCategory.java
* See the License for the specific language governing permissions and * limitations under the License. */ package org.gradle.internal.operations; /** * Classifies a build operation such that executors and event listeners can * react differently depending on this type. * * @since 4.0 */ public enum BuildOperationCategory implements BuildOperationMetadata { /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 2.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ClosingFutureFinishToValueAndCloserTest.java
import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutionException; import java.util.concurrent.Executor; import java.util.concurrent.ExecutorService; /** * Tests for {@link ClosingFuture} that exercise {@link * ClosingFuture#finishToValueAndCloser(ValueAndCloserConsumer, Executor)}. */ public class ClosingFutureFinishToValueAndCloserTest extends AbstractClosingFutureTest {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 5.7K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/api/internal/tasks/SnapshotTaskInputsBuildOperationResult.java
* * <p> * These two operations should be captured separately, but for historical reasons we don't yet do that. * To reproduce this composite operation we capture across executors by starting an operation * in {@link MarkSnapshottingInputsStartedStep} and finished in {@link MarkSnapshottingInputsFinishedStep}. * </p> */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jul 07 15:20:39 UTC 2023 - 3.7K bytes - Viewed (0) -
platforms/core-execution/hashing/src/test/groovy/org/gradle/internal/hash/HashingTest.groovy
package org.gradle.internal.hash import spock.lang.Specification import static java.lang.Thread.currentThread import static java.util.concurrent.CompletableFuture.supplyAsync import static java.util.concurrent.Executors.newFixedThreadPool class HashingTest extends Specification { def 'cannot call hash multiple times'() { given: def hasher = Hashing.newHasher() hasher.putInt(1) hasher.hash()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:43:29 UTC 2023 - 3.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/FluentFutureTest.java
ScheduledExecutorService executor = newScheduledThreadPool(1); try { FluentFuture<?> f = FluentFuture.from(SettableFuture.create()).withTimeout(0, SECONDS, executor); ExecutionException e = assertThrows(ExecutionException.class, () -> f.get()); assertThat(e).hasCauseThat().isInstanceOf(TimeoutException.class); } finally { executor.shutdown(); } }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 13 14:28:25 UTC 2024 - 5.7K bytes - Viewed (0)