- Sort Score
- Result 10 results
- Languages All
Results 481 - 490 of 1,082 for concurrent (1.17 sec)
-
src/main/java/org/codelibs/fess/app/web/admin/webauth/EditForm.java
* Stored as a long value representing milliseconds since epoch. * Used for audit trail and concurrency control. */ @ValidateTypeFailure public Long updatedTime; /** * The version number of the web authentication configuration for optimistic locking. * This field is required to prevent concurrent modification conflicts * by ensuring the configuration hasn't been modified by another process. */Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 2.4K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Stream.kt
import java.net.SocketTimeoutException import java.util.ArrayDeque import okhttp3.Headers import okhttp3.internal.concurrent.Lockable import okhttp3.internal.concurrent.assertLockNotHeld import okhttp3.internal.concurrent.notifyAll import okhttp3.internal.concurrent.wait import okhttp3.internal.concurrent.withLock import okhttp3.internal.http2.flowcontrol.WindowCounter import okhttp3.internal.toHeaderList import okio.AsyncTimeout
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Mon Jul 07 18:57:05 UTC 2025 - 22.4K bytes - Viewed (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>() @SynchronizedRegistered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 2.1K bytes - Viewed (0) -
impl/maven-core/src/test/java/org/apache/maven/plugin/internal/DefaultLegacySupportTest.java
* KIND, either express or implied. See the License for the * specific language governing permissions and limitations * under the License. */ package org.apache.maven.plugin.internal; import java.util.concurrent.CountDownLatch; import org.apache.maven.execution.DefaultMavenExecutionRequest; import org.apache.maven.execution.MavenExecutionRequest; import org.apache.maven.execution.MavenSession; import org.junit.jupiter.api.Test;
Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Fri Jun 06 14:28:57 UTC 2025 - 2.4K bytes - Viewed (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. */Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 1.9K bytes - Viewed (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:
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Oct 02 19:27:26 UTC 2025 - 2.1K bytes - Viewed (0) -
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. */
Registered: Wed Dec 31 11:36:14 UTC 2025 - Last Modified: Fri Apr 11 20:57:49 UTC 2025 - 2.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/scheduler/EditForm.java
*/ @Required @Size(max = 1000) public String id; /** * The version number of the scheduler for optimistic locking. * This field is required to prevent concurrent modification conflicts * by ensuring the scheduler hasn't been modified by another process. */ @Required @ValidateTypeFailure public Integer versionNo;Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 1.8K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/kt/ConfigureTimeouts.kt
* See the License for the specific language governing permissions and * limitations under the License. */ package okhttp3.recipes.kt import java.util.concurrent.TimeUnit import okhttp3.OkHttpClient import okhttp3.Request class ConfigureTimeouts { private val client: OkHttpClient = OkHttpClient .Builder() .connectTimeout(5, TimeUnit.SECONDS)Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 1.3K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/CacheControlJvmTest.kt
*/ package okhttp3 import assertk.assertThat import assertk.assertions.isEqualTo import assertk.assertions.isFalse import assertk.assertions.isSameAs import assertk.assertions.isTrue import java.util.concurrent.TimeUnit import kotlin.test.assertFailsWith import okhttp3.CacheControl.Companion.parse import okhttp3.Headers.Companion.headersOf import org.junit.jupiter.api.Test class CacheControlJvmTest { @TestRegistered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 7.4K bytes - Viewed (0)