thead - Code Search

android/guava-testlib/src/com/google/common/testing/TearDownStack.java

import java.util.LinkedList;
import java.util.List;
import java.util.logging.Level;
import java.util.logging.Logger;

/**
 * A {@code TearDownStack} contains a stack of {@link TearDown} instances.
 *
 * <p>This class is thread-safe.
 *
 * @author Kevin Bourrillion
 * @since 10.0
 */
@GwtCompatible
@ElementTypesAreNonnullByDefault
public class TearDownStack implements TearDownAccepter {

Registered: Fri Nov 01 12:43:10 UTC 2024

- Last Modified: Fri Jun 21 10:19:29 UTC 2024

- 2.5K bytes

- Viewed (0)

github.com/google/guava

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

   * Futures#addCallback addCallback()}.
   *
   * <p>Memory consistency effects: Actions in a thread prior to adding a listener <a
   * href="https://docs.oracle.com/javase/specs/jls/se7/html/jls-17.html#jls-17.4.5">
   * <i>happen-before</i></a> its execution begins, perhaps in another thread.
   *
   * <p>Guava implementations of {@code ListenableFuture} promptly release references to listeners

Registered: Fri Nov 01 12:43:10 UTC 2024

- Last Modified: Mon Jun 26 21:13:41 UTC 2023

- 8K bytes

- Viewed (0)

github.com/google/guava

guava/src/com/google/common/cache/Cache.java

 * evicted or manually invalidated. The common way to build instances is using {@link CacheBuilder}.
 *
 * <p>Implementations of this interface are expected to be thread-safe, and can be safely accessed
 * by multiple concurrent threads.
 *
 * @param <K> the type of the cache's keys, which are not permitted to be null

Registered: Fri Nov 01 12:43:10 UTC 2024

- Last Modified: Sun Aug 07 02:38:22 UTC 2022

- 7.9K bytes

- Viewed (0)

github.com/google/guava

guava/src/com/google/common/eventbus/AllowConcurrentEvents.java

import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;

/**
 * Marks an event subscriber method as being thread-safe. This annotation indicates that EventBus
 * may invoke the event subscriber simultaneously from multiple threads.
 *
 * <p>This does not mark the method, and so should be used in combination with {@link Subscribe}.
 *

Registered: Fri Nov 01 12:43:10 UTC 2024

- Last Modified: Thu Apr 22 13:05:46 UTC 2021

- 1.2K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/test/java/okhttp3/internal/cache2/RelayTest.kt

    val relay = edit(file, pipe.source, metadata, 5)
    val future1 = executor.submit(sourceReader(relay.newSource()))
    val future2 = executor.submit(sourceReader(relay.newSource()))
    Thread.sleep(500)
    sink.writeUtf8("abcdefghij")
    Thread.sleep(500)
    sink.writeUtf8("klmnopqrst")
    sink.close()
    assertThat<ByteString>(future1.get())
      .isEqualTo("abcdefghijklmnopqrst".encodeUtf8())

Registered: Fri Nov 01 11:42:11 UTC 2024

- Last Modified: Thu Apr 11 22:09:35 UTC 2024

- 8.1K bytes

- Viewed (0)

github.com/google/guava

guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/ForwardingSortedMultiset.java

 * method.
 *
 * <p>The {@code standard} methods and any collection views they return are not guaranteed to be
 * thread-safe, even when all of the methods that they depend on are thread-safe.
 *
 * @author Louis Wasserman
 */
@ElementTypesAreNonnullByDefault
public abstract class ForwardingSortedMultiset<E extends @Nullable Object>

Registered: Fri Nov 01 12:43:10 UTC 2024

- Last Modified: Tue Jan 23 18:43:40 UTC 2024

- 8.2K bytes

- Viewed (0)

github.com/istio/istio

bin/update_ztunnel.sh

# $1 = repo
function getSha() {
  local dir result
  dir=$(mktemp -d)
  git clone --depth=1 "https://github.com/istio/${1}.git" -b "${UPDATE_BRANCH}" "${dir}"

  result="$(cd "${dir}" && git rev-parse HEAD)"
  rm -rf "${dir}"

  echo "${result}"
}

Registered: Wed Nov 06 22:53:10 UTC 2024

- Last Modified: Tue Apr 11 17:50:01 UTC 2023

- 1.1K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/view/index.jsp

<%@page pageEncoding="UTF-8" contentType="text/html; charset=UTF-8"%><!DOCTYPE html>
<html>
<head profile="http://a9.com/-/spec/opensearch/1.1/">
<meta charset="utf-8">
<meta name="viewport" content="width=device-width, initial-scale=1">
<meta http-equiv="X-UA-Compatible" content="IE=edge">
<title><la:message key="labels.search_title" /></title>
<c:if test="${osddLink}">
	<link rel="search" type="application/opensearchdescription+xml"
		href="${fe:url('/osdd')}"

Registered: Thu Oct 31 13:40:30 UTC 2024

- Last Modified: Sat Oct 26 01:07:52 UTC 2024

- 6.9K bytes

- Viewed (0)

github.com/google/guava

guava-tests/test/com/google/common/cache/CacheBuilderTest.java

    cache.getUnchecked("a");
    shouldWait.set(true);

    final CountDownLatch computationStarted = new CountDownLatch(1);
    final CountDownLatch computationComplete = new CountDownLatch(1);
    new Thread(
            new Runnable() {
              @Override
              public void run() {
                computationStarted.countDown();
                cache.getUnchecked("b");

Registered: Fri Nov 01 12:43:10 UTC 2024

- Last Modified: Fri Oct 18 15:00:32 UTC 2024

- 24.9K bytes

- Viewed (0)

github.com/google/guava

guava/src/com/google/common/collect/ConsumingQueueIterator.java

import org.checkerframework.checker.nullness.qual.Nullable;

/**
 * An Iterator implementation which draws elements from a queue, removing them from the queue as it
 * iterates. This class is not thread safe.
 */
@GwtCompatible
@ElementTypesAreNonnullByDefault
final class ConsumingQueueIterator<T extends @Nullable Object> extends AbstractIterator<T> {
  private final Queue<T> queue;

Registered: Fri Nov 01 12:43:10 UTC 2024

- Last Modified: Sat Jan 21 14:48:03 UTC 2023

- 1.5K bytes

- Viewed (0)

Search Options