- Sort Score
- Num 10 results
- Language All
Results 211 - 220 of 855 for concurrent (0.05 seconds)
-
futures/failureaccess/pom.xml
<version>1.0.3</version> <packaging>jar</packaging> <name>Guava InternalFutureFailureAccess and InternalFutures</name> <description> Contains com.google.common.util.concurrent.internal.InternalFutureFailureAccess and InternalFutures. Most users will never need to use this artifact. Its classes are conceptually a part of Guava, but they're in this separate
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Oct 02 19:27:26 GMT 2025 - 5.4K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureFallbackAtomicHelperTest.java
*/ package com.google.common.util.concurrent; import static com.google.common.base.StandardSystemProperty.JAVA_SPECIFICATION_VERSION; import static com.google.common.truth.Truth.assertThat; import com.google.common.collect.ImmutableSet; import java.lang.reflect.Method; import java.lang.reflect.Modifier; import java.net.URLClassLoader; import java.util.Set; import java.util.concurrent.atomic.AtomicReferenceFieldUpdater;
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue May 13 18:46:00 GMT 2025 - 7.3K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/ReflectionFreeAssertThrows.java
import com.google.common.collect.ImmutableMap; import com.google.common.util.concurrent.TestExceptions.SomeCheckedException; import com.google.common.util.concurrent.TestExceptions.SomeError; import com.google.common.util.concurrent.TestExceptions.SomeOtherCheckedException; import com.google.common.util.concurrent.TestExceptions.SomeUncheckedException; import com.google.errorprone.annotations.CanIgnoreReturnValue;
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 7K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskLogger.kt
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package okhttp3.internal.concurrent import java.util.logging.Level import java.util.logging.Logger internal inline fun Logger.taskLog( task: Task, queue: TaskQueue, messageBlock: () -> String, ) { if (isLoggable(Level.FINE)) {
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Fri Dec 27 13:39:56 GMT 2024 - 2.6K bytes - Click Count (0) -
android/guava-testlib/src/com/google/common/testing/TestLogHandler.java
* limitations under the License. */ package com.google.common.testing; import com.google.common.annotations.GwtCompatible; import com.google.errorprone.annotations.concurrent.GuardedBy; import java.util.ArrayList; import java.util.Collections; import java.util.List; import java.util.logging.Handler; import java.util.logging.LogRecord; import org.jspecify.annotations.NullMarked;
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 2.8K bytes - Click Count (0) -
build-logic/cleanup/src/main/kotlin/gradlebuild/cleanup/services/DaemonTracker.kt
import org.gradle.api.tasks.testing.TestListener import org.gradle.api.tasks.testing.TestResult import org.gradle.process.ExecOperations import org.slf4j.LoggerFactory import java.util.concurrent.ConcurrentHashMap import javax.inject.Inject private val logger = LoggerFactory.getLogger("daemonTracker") abstract class DaemonTracker : BuildService<DaemonTracker.Params>, AutoCloseable {
Created: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Mon Jan 08 12:45:57 GMT 2024 - 3.4K bytes - Click Count (0) -
docs/pt/docs/async.md
### Hambúrgueres concorrentes { #concurrent-burgers } Você vai com seu _crush_ na lanchonete, e fica na fila enquanto o caixa pega os pedidos das pessoas na sua frente. 😍 <img src="/img/async/concurrent-burgers/concurrent-burgers-01.png" class="illustration"> Então chega a sua vez, você pede dois saborosos hambúrgueres para você e seu _crush_. 🍔🍔Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Wed Nov 12 16:23:57 GMT 2025 - 25.8K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java
*/ package com.google.common.util.concurrent; import static com.google.common.base.Preconditions.checkNotNull; import static com.google.common.util.concurrent.Uninterruptibles.getUninterruptibly; import static java.util.concurrent.Executors.newCachedThreadPool; import com.google.common.annotations.GwtIncompatible; import com.google.common.annotations.J2ktIncompatible; import java.util.concurrent.Executor; import java.util.concurrent.Future;
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Jul 17 15:26:41 GMT 2025 - 7.5K bytes - Click Count (0) -
guava/src/com/google/common/util/concurrent/WrappingScheduledExecutorService.java
* the License. */ package com.google.common.util.concurrent; import com.google.common.annotations.GwtIncompatible; import com.google.common.annotations.J2ktIncompatible; import java.util.concurrent.Callable; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.ScheduledFuture; import java.util.concurrent.TimeUnit; import org.jspecify.annotations.Nullable; /**
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 2.4K bytes - Click Count (0) -
compat/maven-embedder/src/main/java/org/apache/maven/cli/transfer/SimplexTransferListener.java
* under the License. */ package org.apache.maven.cli.transfer; import java.util.ArrayList; import java.util.List; import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.CountDownLatch; import java.util.function.Consumer; import org.eclipse.aether.transfer.AbstractTransferListener; import org.eclipse.aether.transfer.TransferCancelledException;
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Fri Nov 08 08:49:11 GMT 2024 - 8.4K bytes - Click Count (0)