Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 811 - 820 of 1,083 for concurrency (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  2. github.com/google/guava

    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.2K bytes
    - Click Count (0)
  3. github.com/codelibs/fess

    src/main/java/org/codelibs/fess/helper/CrawlingConfigHelper.java 

     */
package org.codelibs.fess.helper;

import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.TimeUnit;
import java.util.regex.Pattern;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.codelibs.core.lang.StringUtil;
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 19.5K bytes
    - Click Count (1)
  4. github.com/codelibs/fess-suggest

    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)
  5. github.com/square/okhttp

    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)
  6. github.com/codelibs/fess-suggest

    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)
  7. github.com/square/okhttp

    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)
  8. github.com/google/guava

    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)
  9. github.com/google/guava

    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)
  10. github.com/google/guava

    android/guava/src/com/google/common/collect/RegularImmutableSortedSet.java 

                return false;
          }
        }
        return true;
      } catch (ClassCastException e) {
        return false;
      } catch (NoSuchElementException e) {
        return false; // concurrent change to other set
      }
    }
    return containsAll(that);
  }

  @Override
  public E first() {
    if (isEmpty()) {
      throw new NoSuchElementException();
    }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Sep 22 21:07:18 GMT 2025
    - 8.8K bytes
    - Click Count (0)
  11. github.com/elastic/elasticsearch

    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)
Back to Top