Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 971 - 980 of 1,335 for concurrent (0.29 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. .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 the
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Nov 17 18:47:47 GMT 2023
    - 5.8K bytes
    - Click Count (0)
Back to Top