- Sort Score
- Num 10 results
- Language All
Results 781 - 790 of 1,335 for concurrent (0.22 seconds)
-
build-logic-commons/gradle-plugin/src/main/kotlin/gradlebuild.collect-failed-tasks.gradle.kts
import io.gitlab.arturbosch.detekt.Detekt import org.gradle.tooling.events.task.TaskFailureResult import org.gradle.tooling.events.task.TaskOperationResult import java.io.Serializable import java.util.concurrent.CopyOnWriteArrayList /** * Register a build service that monitors compilation tasks and code quality tasks (Checkstyle/CodeNarc/detekt) * and reports them as TeamCity build problems. */
Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Fri Apr 11 20:57:49 GMT 2025 - 2.4K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/RecordingCallback.kt
* See the License for the specific language governing permissions and * limitations under the License. */ package okhttp3 import java.io.IOException import java.util.concurrent.TimeUnit /** * Records received HTTP responses so they can be later retrieved by tests. */ class RecordingCallback : Callback { private val responses = mutableListOf<RecordedResponse>() @SynchronizedCreated: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Fri Dec 27 13:39:56 GMT 2024 - 2.1K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/LazyLogger.java
* or implied. See the License for the specific language governing permissions and limitations under * the License. */ package com.google.common.util.concurrent; import com.google.common.annotations.GwtCompatible; import java.util.logging.Logger; import org.jspecify.annotations.Nullable; /** A holder for a {@link Logger} that is initialized only when requested. */Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 1.9K bytes - Click Count (0) -
futures/listenablefuture1/pom.xml
<version>26.0-android</version> </parent> <artifactId>listenablefuture</artifactId> <version>1.0</version> <name>Guava ListenableFuture only</name> <description> Contains Guava's com.google.common.util.concurrent.ListenableFuture class, without any of its other classes -- but is also available in a second "version" that omits the class to avoid conflicts with the copy in Guava itself. The idea is:
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Oct 02 19:27:26 GMT 2025 - 2.1K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/exec/ThumbnailGeneratorTest.java
*/ package org.codelibs.fess.exec; import java.io.ByteArrayOutputStream; import java.io.File; import java.io.PrintStream; import java.lang.reflect.Method; import java.util.concurrent.ExecutorService; import java.util.concurrent.atomic.AtomicInteger; import org.codelibs.core.misc.DynamicProperties; import org.codelibs.fess.exception.ContainerNotAvailableException; import org.codelibs.fess.helper.SystemHelper;
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 11.2K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/multichannel/ChannelInfo.java
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */ package jcifs.internal.smb2.multichannel; import java.util.List; import java.util.concurrent.CopyOnWriteArrayList; import java.util.concurrent.atomic.AtomicLong; import jcifs.SmbTransport; import jcifs.internal.CommonServerMessageBlock; /** * Information about a multi-channel connection */ public class ChannelInfo {Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 21 11:13:46 GMT 2025 - 10.6K bytes - Click Count (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/CrawlerContext.java
* governing permissions and limitations under the License. */ package org.codelibs.fess.crawler; import java.util.Set; import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicLong; import org.codelibs.core.collection.LruHashSet; import org.codelibs.fess.crawler.filter.UrlFilter; import org.codelibs.fess.crawler.interval.IntervalController;
Created: Sun Apr 12 03:50:13 GMT 2026 - Last Modified: Wed Dec 31 09:07:38 GMT 2025 - 9K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http/CancelTest.kt
import assertk.assertions.isEqualTo import assertk.assertions.startsWith import assertk.fail import java.io.IOException import java.net.ServerSocket import java.net.Socket import java.util.concurrent.CountDownLatch import java.util.concurrent.TimeUnit.MILLISECONDS import javax.net.ServerSocketFactory import javax.net.SocketFactory import kotlin.test.assertFailsWith import mockwebserver3.MockResponse import mockwebserver3.MockWebServer
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Nov 04 19:13:52 GMT 2025 - 9.4K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/ConnectionCoalescingTest.kt
import java.net.InetAddress import java.net.InetSocketAddress import java.net.Proxy import java.security.cert.X509Certificate import java.util.Arrays import java.util.concurrent.CountDownLatch import java.util.concurrent.atomic.AtomicInteger import java.util.concurrent.atomic.AtomicReference import javax.net.ssl.HostnameVerifier import javax.net.ssl.SSLPeerUnverifiedException import javax.net.ssl.SSLSession
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Thu Jun 19 11:44:16 GMT 2025 - 19.1K bytes - Click Count (0) -
android/guava/pom.xml
<Export-Package> !com.google.common.base.internal, !com.google.common.util.concurrent.internal, !META-INF.*, com.google.common.* </Export-Package> <Import-Package> com.google.common.util.concurrent.internal, org.jspecify.annotations;resolution:=optional, javax.crypto.*;resolution:=optional,Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Nov 17 21:36:50 GMT 2025 - 9.8K bytes - Click Count (0)