thead - Code Search

docs/bucket/replication/README.md

![put](https://raw.githubusercontent.com/minio/minio/master/docs/bucket/replication/PUT_bucket_replication.png)

![head](https://raw.githubusercontent.com/minio/minio/master/docs/bucket/replication/HEAD_bucket_replication.png)

## Replica Modification sync

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Tue Jan 24 23:46:33 UTC 2023

- 18.2K bytes

- Viewed (0)

github.com/tensorflow/tensorflow

tensorflow/c/eager/parallel_device/parallel_device_lib.cc

//
// DeviceThread itself is thread-safe, in that StartExecute will block if there
// is a pending execution. Since StartExecute is equivalent to grabbing a lock,
// multiple DeviceThreads should always be accessed in the same order to avoid
// deadlocks.
class DeviceThread {
 public:
  // Starts a background thread waiting for `StartExecute`.

Registered: Tue Nov 05 12:39:12 UTC 2024

- Last Modified: Mon Oct 21 04:14:14 UTC 2024

- 25.9K bytes

- Viewed (0)

github.com/apache/maven

impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/PlexusContainerCapsuleFactory.java

            }
        });

        ClassLoader oldCL = Thread.currentThread().getContextClassLoader();
        try {
            container.setLookupRealm(null);
            container.setLoggerManager(createLoggerManager());
            container.getLoggerManager().setThresholds(toPlexusLoggingLevel(context.loggerLevel));
            Thread.currentThread().setContextClassLoader(container.getContainerRealm());

Registered: Sun Nov 03 03:35:11 UTC 2024

- Last Modified: Fri Oct 25 12:31:46 UTC 2024

- 13.6K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/main/kotlin/okhttp3/internal/connection/RoutePlanner.kt

 *
 * It is possible to cancel the finding process by canceling its call.
 *
 * Implementations of this interface are not thread-safe. Each instance is thread-confined to the
 * thread executing the call.
 */
interface RoutePlanner {
  val address: Address

  /** Follow-ups for failed plans and plans that lost a race. */
  val deferredPlans: ArrayDeque<Plan>

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

- Last Modified: Wed Dec 20 23:27:07 UTC 2023

- 4.2K bytes

- Viewed (0)

github.com/codelibs/corelib

src/test/java/org/codelibs/core/lang/ClassLoaderUtilTest.java

        final ClassLoader context = Thread.currentThread().getContextClassLoader();
        try {
            final ClassLoader cl = new URLClassLoader(new URL[0], getClass().getClassLoader());
            Thread.currentThread().setContextClassLoader(cl);
            assertThat(ClassLoaderUtil.getClassLoader(TestCase.class), is(sameInstance(cl)));
        } finally {
            Thread.currentThread().setContextClassLoader(context);

Registered: Fri Nov 01 20:58:10 UTC 2024

- Last Modified: Thu Mar 07 01:59:08 UTC 2024

- 3K bytes

- Viewed (0)

github.com/google/guava

android/guava/src/com/google/common/escape/Platform.java

@ElementTypesAreNonnullByDefault
final class Platform {
  private Platform() {}

  /** Returns a thread-local 1024-char array. */
  static char[] charBufferFromThreadLocal() {
    // requireNonNull accommodates Android's @RecentlyNullable annotation on ThreadLocal.get
    return requireNonNull(DEST_TL.get());
  }

  /**
   * A thread-local destination buffer to keep us from creating new buffers. The starting size is

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

- Last Modified: Fri Dec 15 19:31:54 UTC 2023

- 1.6K bytes

- Viewed (0)

github.com/google/guava

guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java

@ElementTypesAreNonnullByDefault
public final class JdkFutureAdapters {
  /**
   * Assigns a thread to the given {@link Future} to provide {@link ListenableFuture} functionality.
   *
   * <p><b>Warning:</b> If the input future does not already implement {@code ListenableFuture}, the
   * returned future will emulate {@link ListenableFuture#addListener} by taking a thread from an

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

- Last Modified: Thu Dec 14 20:35:03 UTC 2023

- 7.5K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/view/admin/boostdoc/admin_boostdoc_edit.jsp

<%@page pageEncoding="UTF-8" contentType="text/html; charset=UTF-8" %><!DOCTYPE html>
<html>
<head>
    <meta charset="UTF-8">
    <title><la:message key="labels.admin_brand_title"/> | <la:message
            key="labels.boost_document_rule_configuration"/></title>
    <jsp:include page="/WEB-INF/view/common/admin/head.jsp"></jsp:include>
</head>
<body class="hold-transition sidebar-mini">
<div class="wrapper">

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

- Last Modified: Wed Feb 12 20:25:27 UTC 2020

- 5K bytes

- Viewed (0)

github.com/codelibs/fess-suggest

.github/workflows/codeql-analysis.yml

        # We must fetch at least the immediate parents so that if this is
        # a pull request then we can checkout the head.
        fetch-depth: 2

    # If this run was triggered by a pull request event, then checkout
    # the head of the pull request instead of the merge commit.
    - run: git checkout HEAD^2
      if: ${{ github.event_name == 'pull_request' }}

    # Initializes the CodeQL tools for scanning.

Registered: Fri Nov 08 09:08:12 UTC 2024

- Last Modified: Sat Dec 23 10:29:00 UTC 2023

- 2.9K bytes

- Viewed (0)

github.com/codelibs/curl4j

src/main/java/org/codelibs/curl/Curl.java

    }

    public static CurlRequest delete(final String url) {
        return new CurlRequest(Method.DELETE, url);
    }

    public static CurlRequest head(final String url) {
        return new CurlRequest(Method.HEAD, url);
    }

    public static CurlRequest options(final String url) {
        return new CurlRequest(Method.OPTIONS, url);
    }

Registered: Thu Oct 31 02:32:13 UTC 2024

- Last Modified: Mon Nov 14 21:05:19 UTC 2022

- 1.7K bytes

- Viewed (0)

Search Options