Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 411 - 420 of 1,325 for concurrency (0.1 seconds)

  2. github.com/google/guava

    android/guava-tests/test/com/google/common/util/concurrent/TrustedInputFutureTest.java 

     * 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.common.util.concurrent.AbstractFuture.TrustedFuture;
import org.jspecify.annotations.NullUnmarked;
import org.jspecify.annotations.Nullable;

/**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 15:59:55 GMT 2026
    - 1.3K bytes
    - Click Count (0)
  3. github.com/google/guava

    guava-tests/test/com/google/common/util/concurrent/UntrustedInputFutureTest.java 

     * 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.common.util.concurrent.AbstractFuture.TrustedFuture;
import org.jspecify.annotations.NullUnmarked;
import org.jspecify.annotations.Nullable;

/**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 15:59:55 GMT 2026
    - 1.3K bytes
    - Click Count (0)
  4. github.com/codelibs/jcifs

    src/test/java/jcifs/smb1/smb1/BufferCacheSecurityTest.java 

    import static org.junit.jupiter.api.Assertions.assertTrue;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;

import org.junit.jupiter.api.Test;

/**
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 9.6K bytes
    - Click Count (0)
  5. github.com/codelibs/fess-suggest

    src/main/java/org/codelibs/fess/suggest/concurrent/Deferred.java 

     * governing permissions and limitations under the License.
 */
package org.codelibs.fess.suggest.concurrent;

import java.util.ArrayList;
import java.util.Queue;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.TimeUnit;
import java.util.function.Consumer;

import org.codelibs.core.exception.InterruptedRuntimeException;
    Created: Fri Apr 17 09:08:13 GMT 2026
    - Last Modified: Fri Jul 04 14:00:23 GMT 2025
    - 7.8K bytes
    - Click Count (0)
  6. github.com/square/okhttp

    okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HttpOverHttp2Test.kt 

    import java.time.Duration
import java.util.Arrays
import java.util.concurrent.BlockingQueue
import java.util.concurrent.CountDownLatch
import java.util.concurrent.Executors
import java.util.concurrent.LinkedBlockingQueue
import java.util.concurrent.SynchronousQueue
import java.util.concurrent.TimeUnit
import java.util.concurrent.TimeoutException
import java.util.concurrent.atomic.AtomicReference
import javax.net.ssl.SSLException
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 67.5K bytes
    - Click Count (0)
  7. github.com/google/guava

    android/guava/src/com/google/common/util/concurrent/ServiceManagerBridge.java 

     * 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.collect.ImmutableMultimap;
import com.google.common.util.concurrent.Service.State;

/**
 * Superinterface of {@link ServiceManager} to introduce a bridge method for {@code
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Dec 21 03:10:51 GMT 2024
    - 1.2K bytes
    - Click Count (0)
  8. github.com/google/guava

    guava-tests/test/com/google/common/util/concurrent/AggregateFutureStateFallbackAtomicHelperTest.java 

    import java.lang.reflect.Field;
import java.lang.reflect.Method;
import java.lang.reflect.Modifier;
import java.net.URLClassLoader;
import java.util.Set;
import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
import java.util.concurrent.atomic.AtomicReferenceFieldUpdater;
import junit.framework.TestCase;
import junit.framework.TestSuite;
import org.jspecify.annotations.NullUnmarked;

/**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 6.7K bytes
    - Click Count (0)
  9. github.com/google/guava

    android/guava-tests/test/com/google/common/util/concurrent/ClosingFutureLeakTest.java 

     */

package com.google.common.util.concurrent;

import static com.google.common.testing.GcFinalization.awaitClear;
import static com.google.common.truth.Truth.assertThat;
import static com.google.common.util.concurrent.MoreExecutors.directExecutor;

import com.google.common.annotations.GwtIncompatible;
import com.google.common.annotations.J2ktIncompatible;
import com.google.common.util.concurrent.AbstractClosingFutureTest.TestCloseable;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 02:20:33 GMT 2026
    - 1.8K bytes
    - Click Count (0)
  10. github.com/google/guava

    android/guava/src/com/google/common/util/concurrent/ForwardingCondition.java 

     * the License.
 */

package com.google.common.util.concurrent;

import com.google.common.annotations.GwtIncompatible;
import com.google.common.annotations.J2ktIncompatible;
import java.util.Date;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.Condition;

/** Forwarding wrapper around a {@code Condition}. */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jul 24 18:55:30 GMT 2025
    - 1.8K bytes
    - Click Count (0)
  11. github.com/google/guava

    guava-tests/test/com/google/common/util/concurrent/ClosingFutureLeakTest.java 

     */

package com.google.common.util.concurrent;

import static com.google.common.testing.GcFinalization.awaitClear;
import static com.google.common.truth.Truth.assertThat;
import static com.google.common.util.concurrent.MoreExecutors.directExecutor;

import com.google.common.annotations.GwtIncompatible;
import com.google.common.annotations.J2ktIncompatible;
import com.google.common.util.concurrent.AbstractClosingFutureTest.TestCloseable;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 02:20:33 GMT 2026
    - 1.8K bytes
    - Click Count (0)
Back to Top