- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 299 for task (0.16 sec)
-
src/main/java/org/codelibs/curl/CurlRequest.java
Java - Registered: Thu May 09 15:34:10 GMT 2024 - Last Modified: Sun Feb 12 12:21:25 GMT 2023 - 12.3K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/project/ProjectModelResolver.java
pool.shutdown(); } return true; } }; pool.submit(task); return task; }); result = future.get(); } catch (Exception e) { throw new UnresolvableModelException(e, parent.getGroupId(), parent.getArtifactId(), parent.getVersion());
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Thu Apr 25 14:13:36 GMT 2024 - 15.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/RateLimiter.java
* <p>As an example, imagine that we have a list of tasks to execute, but we don't want to submit * more than 2 per second: * * <pre>{@code * final RateLimiter rateLimiter = RateLimiter.create(2.0); // rate is "2 permits per second" * void submitTasks(List<Runnable> tasks, Executor executor) { * for (Runnable task : tasks) { * rateLimiter.acquire(); // may wait * executor.execute(task); * } * } * }</pre> *
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 18.2K bytes - Viewed (0) -
build-logic/build-init-samples/src/main/kotlin/gradlebuild/samples/SamplesGenerator.kt
> Task :$subprojectName:compileJava NO-SOURCE """.trimIndent() else "" val extraCompileTestJava = if (descriptor.language != Language.JAVA) """ > Task :$subprojectName:compileTestJava NO-SOURCE """.trimIndent() else "" val extraKotlinCheckTask = if (descriptor.language === Language.KOTLIN) """
Plain Text - Registered: Wed May 01 11:36:15 GMT 2024 - Last Modified: Tue Feb 06 17:51:21 GMT 2024 - 13.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
allTasks.add(setFutureCompleteExceptionallyRunnable); allTasks.add(setFutureCancelRunnable); for (int k = 0; k < 50; k++) { // For each listener we add a task that submits it to the executor directly for the blocking // get use case and another task that adds it as a listener to the future to exercise both // racing addListener calls and addListener calls completing after the future completes. final Runnable listener =
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 46.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/hash/BloomFilterTest.java
assertThat(exceptions).isEmpty(); } private static List<Throwable> runThreadsAndReturnExceptions(int numThreads, Runnable task) { List<Thread> threads = new ArrayList<>(numThreads); final List<Throwable> exceptions = new ArrayList<>(numThreads); for (int i = 0; i < numThreads; i++) { Thread thread = new Thread(task); thread.setUncaughtExceptionHandler(
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Nov 09 22:49:56 GMT 2023 - 21.3K bytes - Viewed (0) -
build-logic/integration-testing/src/main/kotlin/gradlebuild/integrationtests/shared-configuration.kt
import org.gradle.api.file.Directory import org.gradle.api.tasks.GroovySourceDirectorySet import org.gradle.api.tasks.InputDirectory import org.gradle.api.tasks.InputFiles import org.gradle.api.tasks.PathSensitive import org.gradle.api.tasks.PathSensitivity import org.gradle.api.tasks.SourceSet import org.gradle.api.tasks.SourceSetContainer import org.gradle.api.tasks.TaskProvider import org.gradle.kotlin.dsl.*
Plain Text - Registered: Wed Mar 27 11:36:08 GMT 2024 - Last Modified: Mon Feb 12 13:19:06 GMT 2024 - 11.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/hash/BloomFilterTest.java
assertThat(exceptions).isEmpty(); } private static List<Throwable> runThreadsAndReturnExceptions(int numThreads, Runnable task) { List<Thread> threads = new ArrayList<>(numThreads); final List<Throwable> exceptions = new ArrayList<>(numThreads); for (int i = 0; i < numThreads; i++) { Thread thread = new Thread(task); thread.setUncaughtExceptionHandler(
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Thu Nov 09 22:49:56 GMT 2023 - 21.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt
private val key: String /** Non-null for client web sockets. These can be canceled. */ internal var call: Call? = null /** This task processes the outgoing queues. Call [runWriter] to after enqueueing. */ private var writerTask: Task? = null /** Null until this web socket is connected. Only accessed by the reader thread. */ private var reader: WebSocketReader? = null
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 01 14:21:25 GMT 2024 - 22.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
* * Since we can't ACK settings on the current reader thread (the reader thread can't write) we * execute all peer settings logic on the writer thread. This relies on the fact that the * writer task queue won't reorder tasks; otherwise settings could be applied in the opposite * order than received. */ fun applyAndAckSettings( clearPrevious: Boolean, settings: Settings, ) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 32.6K bytes - Viewed (0)