Search Options

Results per page
Sort
Preferred Languages
Advance

Results 631 - 640 of 985 for concurrent1 (0.14 sec)

  1. android/guava-tests/test/com/google/common/cache/CacheRefreshTest.java

     * the License.
     */
    
    package com.google.common.cache;
    
    import static com.google.common.cache.TestingCacheLoaders.incrementingLoader;
    import static java.util.concurrent.TimeUnit.MILLISECONDS;
    
    import com.google.common.cache.TestingCacheLoaders.IncrementingLoader;
    import com.google.common.testing.FakeTicker;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 4K bytes
    - Viewed (0)
  2. src/cmd/api/main_test.go

    }
    
    var listCache sync.Map // map[string]listImports, keyed by contextName
    
    // listSem is a semaphore restricting concurrent invocations of 'go list'. 'go
    // list' has its own internal concurrency, so we use a hard-coded constant (to
    // allow the I/O-intensive phases of 'go list' to overlap) instead of scaling
    // all the way up to GOMAXPROCS.
    var listSem = make(chan semToken, 2)
    
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Thu Feb 20 03:25:33 UTC 2025
    - 31.4K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/job/CrawlJob.java

    import static org.codelibs.core.stream.StreamUtil.stream;
    
    import java.io.File;
    import java.text.SimpleDateFormat;
    import java.util.ArrayList;
    import java.util.Date;
    import java.util.List;
    import java.util.concurrent.atomic.AtomicInteger;
    
    import org.apache.commons.lang3.StringUtils;
    import org.apache.commons.lang3.SystemUtils;
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 19.6K bytes
    - Viewed (0)
  4. guava-testlib/src/com/google/common/collect/testing/TestsForMapsInJavaUtil.java

    import java.util.LinkedHashMap;
    import java.util.Map;
    import java.util.Map.Entry;
    import java.util.NavigableMap;
    import java.util.SortedMap;
    import java.util.TreeMap;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.ConcurrentSkipListMap;
    import junit.framework.Test;
    import junit.framework.TestSuite;
    
    /**
     * Generates a test suite covering the {@link Map} implementations in the {@link java.util} package.
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Feb 12 16:28:01 UTC 2025
    - 21.8K bytes
    - Viewed (0)
  5. src/test/java/org/codelibs/fess/helper/CrawlingInfoHelperTest.java

    package org.codelibs.fess.helper;
    
    import java.util.ArrayList;
    import java.util.Date;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    import java.util.concurrent.ForkJoinPool;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.atomic.AtomicInteger;
    
    import org.apache.commons.lang3.RandomStringUtils;
    import org.codelibs.fess.Constants;
    import org.codelibs.fess.app.service.CrawlingInfoService;
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Jul 12 05:35:01 UTC 2025
    - 26.6K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/collect/LinkedHashMultimap.java

     *
     * <p>Keys and values may be null. All optional multimap methods are supported, and all returned
     * views are modifiable.
     *
     * <p>This class is not threadsafe when any concurrent operations update the multimap. Concurrent
     * read operations will work correctly. To allow concurrent update operations, wrap your multimap
     * with a call to {@link Multimaps#synchronizedSetMultimap}.
     *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 19.1K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/helper/SystemHelper.java

    import java.util.Map.Entry;
    import java.util.Properties;
    import java.util.Set;
    import java.util.TimeZone;
    import java.util.UUID;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.atomic.AtomicBoolean;
    import java.util.concurrent.atomic.AtomicInteger;
    import java.util.function.Supplier;
    import java.util.regex.Pattern;
    import java.util.stream.Collectors;
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sun Aug 31 08:19:00 UTC 2025
    - 36.6K bytes
    - Viewed (0)
  8. src/test/java/org/codelibs/fess/exec/CrawlerTest.java

    import java.util.ArrayList;
    import java.util.Collections;
    import java.util.Date;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    import java.util.Queue;
    import java.util.concurrent.ConcurrentLinkedQueue;
    import java.util.concurrent.atomic.AtomicBoolean;
    
    import org.codelibs.core.io.FileUtil;
    import org.codelibs.core.lang.StringUtil;
    import org.codelibs.core.misc.DynamicProperties;
    import org.codelibs.fess.Constants;
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 30.5K bytes
    - Viewed (0)
  9. okhttp/src/jvmTest/kotlin/okhttp3/internal/concurrent/TaskLoggerTest.kt

     * 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 okhttp3.internal.concurrent
    
    import assertk.assertThat
    import assertk.assertions.isEqualTo
    import org.junit.jupiter.api.Test
    
    class TaskLoggerTest {
      @Suppress("ktlint")
      @Test fun formatTime() {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/cache/ForwardingLoadingCache.java

    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.base.Preconditions;
    import com.google.common.collect.ImmutableMap;
    import com.google.errorprone.annotations.CanIgnoreReturnValue;
    import java.util.concurrent.ExecutionException;
    
    /**
     * A cache which forwards all its method calls to another cache. Subclasses should override one or
     * more methods to modify the behavior of the backing cache as desired per the <a
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 2.9K bytes
    - Viewed (0)
Back to top