- Sort Score
- Num 10 results
- Language All
Results 971 - 980 of 1,335 for concurrent (0.29 seconds)
-
src/main/java/org/codelibs/fess/suggest/index/operations/ContentIndexingOperations.java
import java.util.List; import java.util.Map; import java.util.concurrent.ExecutorService; import java.util.function.Supplier; import java.util.stream.Stream; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.core.lang.StringUtil; import org.codelibs.fess.suggest.analysis.SuggestAnalyzer; import org.codelibs.fess.suggest.concurrent.Deferred;
Created: Fri Apr 17 09:08:13 GMT 2026 - Last Modified: Sat Mar 14 02:35:38 GMT 2026 - 21.7K bytes - Click Count (0) -
mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/MockWebServerTest.kt
import java.net.HttpURLConnection import java.net.ProtocolException import java.net.SocketTimeoutException import java.nio.charset.StandardCharsets import java.util.Arrays import java.util.concurrent.TimeUnit import java.util.concurrent.atomic.AtomicBoolean import javax.net.ssl.HttpsURLConnection import kotlin.test.assertFailsWith import okhttp3.Headers import okhttp3.Protocol import okhttp3.RecordingHostnameVerifier
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Thu Jul 03 13:16:34 GMT 2025 - 22.3K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/Smb2SigningDigest.java
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */ package jcifs.internal.smb2; import java.security.GeneralSecurityException; import java.security.MessageDigest; import java.util.concurrent.locks.ReentrantLock; import javax.crypto.Mac; import javax.crypto.spec.SecretKeySpec; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import jcifs.internal.CommonServerMessageBlock;
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 9.9K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/suggest/index/contents/document/ESSourceReaderTest.java
import static org.junit.Assert.assertTrue; import java.util.Collections; import java.util.HashMap; import java.util.HashSet; import java.util.Map; import java.util.Random; import java.util.Set; import java.util.concurrent.atomic.AtomicInteger; import org.codelibs.fess.suggest.Suggester; import org.codelibs.fess.suggest.settings.SuggestSettings; import org.codelibs.opensearch.runner.OpenSearchRunner; import org.junit.AfterClass;
Created: Fri Apr 17 09:08:13 GMT 2026 - Last Modified: Sun Nov 23 13:04:17 GMT 2025 - 8.7K bytes - Click Count (0) -
okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourceHttpTest.kt
* limitations under the License. */ package okhttp3.sse.internal import assertk.assertThat import assertk.assertions.containsExactly import assertk.assertions.isEqualTo import java.util.concurrent.TimeUnit import mockwebserver3.MockResponse import mockwebserver3.MockWebServer import mockwebserver3.junit5.StartStop import okhttp3.CallEvent.CallEnd import okhttp3.CallEvent.CallStart
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Nov 04 19:13:52 GMT 2025 - 8.8K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/cache/CacheBuilderFactory.java
import com.google.common.collect.Sets; import com.google.errorprone.annotations.CanIgnoreReturnValue; import java.util.LinkedHashSet; import java.util.List; import java.util.Objects; import java.util.Set; import java.util.concurrent.TimeUnit; import org.jspecify.annotations.NullUnmarked; import org.jspecify.annotations.Nullable; /** * Helper class for creating {@link CacheBuilder} instances with all combinations of several sets of * parameters.Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Mar 18 18:06:14 GMT 2026 - 7.5K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/MonitorTestCase.java
* 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 com.google.common.util.concurrent; import com.google.common.annotations.GwtIncompatible; import com.google.common.annotations.J2ktIncompatible; import com.google.common.testing.NullPointerTester; import com.google.common.testing.TearDownStack;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 02:20:33 GMT 2026 - 8.1K bytes - Click Count (0) -
build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/InternalDistributionArchiveCheckPlugin.java
import javax.inject.Inject; import java.io.File; import java.io.IOException; import java.nio.file.Files; import java.nio.file.Path; import java.util.Arrays; import java.util.List; import java.util.Map; import java.util.concurrent.Callable; import java.util.stream.Collectors; import org.elasticsearch.gradle.internal.conventions.GUtils; public class InternalDistributionArchiveCheckPlugin implements InternalPlugin {Created: Wed Apr 08 16:19:15 GMT 2026 - Last Modified: Tue Jun 01 09:19:30 GMT 2021 - 10.6K bytes - Click Count (0) -
benchmarks/src/main/java/org/elasticsearch/benchmark/search/aggregations/bucket/terms/LongKeyedBucketOrdsBenchmark.java
import org.openjdk.jmh.annotations.Scope; import org.openjdk.jmh.annotations.Setup; import org.openjdk.jmh.annotations.State; import org.openjdk.jmh.annotations.Warmup; import org.openjdk.jmh.infra.Blackhole; import java.util.concurrent.TimeUnit; @Fork(2) @Warmup(iterations = 10) @Measurement(iterations = 5) @BenchmarkMode(Mode.AverageTime) @OutputTimeUnit(TimeUnit.NANOSECONDS) @OperationsPerInvocation(1_000_000) @State(Scope.Benchmark)
Created: Wed Apr 08 16:19:15 GMT 2026 - Last Modified: Fri Feb 19 20:59:23 GMT 2021 - 8.4K bytes - Click Count (0) -
.github/ISSUE_TEMPLATE/feature_addition_request.yaml
- com.google.common.math - com.google.common.net - com.google.common.primitives - com.google.common.reflect - com.google.common.testing - com.google.common.util.concurrent - type: checkboxes attributes: label: Checklist options: - label: > I agree to follow theCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Nov 17 18:47:47 GMT 2023 - 5.8K bytes - Click Count (0)