Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 741 - 750 of 1,334 for concurrent1 (0.06 seconds)

  1. android/guava/src/com/google/common/util/concurrent/SneakyThrows.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.GwtCompatible;
    import com.google.errorprone.annotations.CanIgnoreReturnValue;
    
    /** Static utility method for unchecked throwing of any {@link Throwable}. */
    @GwtCompatible
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Dec 30 18:44:22 GMT 2024
    - 2.4K bytes
    - Click Count (0)
  2. guava/src/com/google/common/cache/ForwardingLoadingCache.java

    import com.google.common.annotations.J2ktIncompatible;
    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
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 03 12:40:22 GMT 2026
    - 3K bytes
    - Click Count (0)
  3. compat/maven-settings-builder/src/main/java/org/apache/maven/settings/building/DefaultSettingsBuildingRequest.java

            if (systemProperties != null) {
                this.systemProperties = new Properties();
                synchronized (systemProperties) { // avoid concurrent modification if someone else sets/removes an unrelated
                    // system property
                    this.systemProperties.putAll(systemProperties);
                }
            } else {
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Oct 25 12:31:46 GMT 2024
    - 4.5K bytes
    - Click Count (0)
  4. impl/maven-core/src/main/java/org/apache/maven/artifact/handler/manager/DefaultArtifactHandlerManager.java

     */
    package org.apache.maven.artifact.handler.manager;
    
    import javax.inject.Inject;
    import javax.inject.Named;
    import javax.inject.Singleton;
    
    import java.util.Map;
    import java.util.Set;
    import java.util.concurrent.ConcurrentHashMap;
    
    import org.apache.maven.api.JavaPathType;
    import org.apache.maven.api.Type;
    import org.apache.maven.api.services.TypeRegistry;
    import org.apache.maven.artifact.handler.ArtifactHandler;
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Jan 10 08:42:00 GMT 2025
    - 3.4K bytes
    - Click Count (0)
  5. build-logic-commons/gradle-plugin/src/main/kotlin/gradlebuild/nullaway/NullawayStatusService.kt

     * limitations under the License.
     */
    
    package gradlebuild.nullaway
    
    import org.gradle.api.services.BuildService
    import org.gradle.api.services.BuildServiceParameters
    import java.io.Closeable
    import java.util.concurrent.ConcurrentHashMap
    
    internal abstract class NullawayStatusService : BuildService<BuildServiceParameters.None>, Closeable {
        private val projectsWithNullAwayEnabled = ConcurrentHashMap.newKeySet<String>()
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Wed Aug 20 13:18:23 GMT 2025
    - 3.8K bytes
    - Click Count (0)
  6. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/AccessTimeoutTarget.java

     * either express or implied. See the License for the specific language
     * governing permissions and limitations under the License.
     */
    package org.codelibs.fess.crawler.client;
    
    import java.util.concurrent.atomic.AtomicBoolean;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.core.lang.ThreadUtil;
    import org.codelibs.core.timer.TimeoutTarget;
    
    /**
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Sun Jul 06 02:13:03 GMT 2025
    - 2.8K bytes
    - Click Count (0)
  7. .github/workflows/lock.yml

    name: 'Lock Threads'
    
    on:
      schedule:
        - cron: '0 0 * * *'
      workflow_dispatch:
    
    permissions:
      issues: write
    
    concurrency:
      group: lock
    
    jobs:
      action:
        runs-on: ubuntu-latest
        steps:
          - uses: dessant/lock-threads@v3
            with:
              github-token: ${{ github.token }}
              issue-inactive-days: '365'
              exclude-any-issue-labels: 'do-not-close'
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Jan 30 03:27:43 GMT 2022
    - 447 bytes
    - Click Count (0)
  8. src/main/java/org/codelibs/fess/thumbnail/ThumbnailManager.java

    import java.util.ArrayList;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    import java.util.concurrent.BlockingQueue;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.LinkedBlockingQueue;
    import java.util.concurrent.TimeUnit;
    import java.util.stream.Stream;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Jan 01 12:47:47 GMT 2026
    - 27.2K bytes
    - Click Count (0)
  9. android/guava-testlib/src/com/google/common/collect/testing/Helpers.java

       *     the size method
       */
      public static <T extends @Nullable Object> Collection<T> misleadingSizeCollection(int delta) {
        // It would be nice to be able to return a real concurrent
        // collection like ConcurrentLinkedQueue, so that e.g. concurrent
        // iteration would work, but that would not be GWT-compatible.
        // We are not "just" inheriting from ArrayList here as this doesn't work for J2kt.
        return new AbstractList<T>() {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 23 21:06:42 GMT 2026
    - 17.2K bytes
    - Click Count (0)
  10. okhttp/src/jvmTest/kotlin/okhttp3/internal/UtilTest.kt

    import assertk.assertions.isEqualTo
    import assertk.assertions.isFalse
    import assertk.assertions.isTrue
    import java.net.InetAddress
    import java.net.ServerSocket
    import java.net.Socket
    import java.util.concurrent.TimeUnit
    import kotlin.time.Duration.Companion.milliseconds
    import kotlin.time.Duration.Companion.nanoseconds
    import okio.buffer
    import okio.source
    import org.junit.jupiter.api.Test
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Fri Dec 27 13:39:56 GMT 2024
    - 3K bytes
    - Click Count (0)
Back to Top