- Sort Score
- Num 10 results
- Language All
Results 171 - 180 of 318 for unlocks (0.05 seconds)
-
internal/once/singleton.go
} } // IsSet will return whether the singleton has been set. func (s *Singleton[T]) IsSet() bool { select { case <-s.set: return true default: return false } } // Set the value and unblock all Get requests. // This may only be called once, a second call will panic. func (s *Singleton[T]) Set(v *T) { s.v = v close(s.set)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Thu Aug 15 12:04:40 GMT 2024 - 952 bytes - Click Count (0) -
cmd/metrics-v3-handler.go
// are provided, we will not return bucket metrics. if bmg, ok := h.metricsData.bucketMGMap[collectorPath]; ok { if len(buckets) == 0 { continue } unLocker := bmg.LockAndSetBuckets(buckets) defer unLocker() } gatherers = append(gatherers, gatherer) } } if len(gatherers) == 0 { return notFoundHandler }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Oct 10 18:57:03 GMT 2025 - 7.7K bytes - Click Count (0) -
mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/MockWebServerTest.kt
connection.setReadTimeout(500) try { connection.getResponseCode() fail<Any>() } catch (expected: SocketTimeoutException) { } // Shutting down the server should unblock the dispatcher. server.shutdown() } @Test fun requestUrlReconstructed() { server.enqueue(MockResponse().setBody("hello world")) val url = server.url("/a/deep/path?key=foo%20bar").toUrl()
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Thu Jul 03 13:16:34 GMT 2025 - 22.3K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/StripedTest.java
import java.util.List; import java.util.Map; import java.util.Set; import java.util.concurrent.Semaphore; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReadWriteLock; import java.util.concurrent.locks.ReentrantLock; import java.util.concurrent.locks.ReentrantReadWriteLock; import junit.framework.TestCase; import org.jspecify.annotations.NullUnmarked; /** * Tests for Striped. *
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 8.1K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/StripedTest.java
import java.util.List; import java.util.Map; import java.util.Set; import java.util.concurrent.Semaphore; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReadWriteLock; import java.util.concurrent.locks.ReentrantLock; import java.util.concurrent.locks.ReentrantReadWriteLock; import junit.framework.TestCase; import org.jspecify.annotations.NullUnmarked; /** * Tests for Striped. *
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 8.1K bytes - Click Count (0) -
docs/ko/docs/_llm-test.md
일부 텍스트 /// /// danger | 위험 일부 텍스트 /// //// //// tab | 정보 탭과 `Info`/`Note`/`Warning`/등의 블록은 제목 번역을 수직 막대(`|`) 뒤에 추가해야 합니다. `scripts/translate.py`의 일반 프롬프트에서 `### Special blocks`와 `### Tab blocks` 섹션을 참고하세요. //// ## 웹 및 내부 링크 { #web-and-internal-links } //// tab | 테스트 링크 텍스트는 번역되어야 하고, 링크 주소는 변경되지 않아야 합니다: * [위의 제목으로 가는 링크](#code-snippets)Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Fri Mar 20 14:06:26 GMT 2026 - 11.7K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/MojoExecutor.java
acquiredProjectLock.unlock(); acquiredAggregatorLock.unlock(); mojos.remove(Thread.currentThread()); } private OwnerReentrantLock getProjectLock(MavenSession session) { SessionData data = session.getSession().getData(); Map<MavenProject, OwnerReentrantLock> locks = data.computeIfAbsent(PROJECT_LOCKS, ConcurrentHashMap::new);Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Thu Jun 12 14:55:55 GMT 2025 - 21K bytes - Click Count (0) -
cmd/erasure-object-conditional_test.go
z.serverPools[0].erasureDisksMu.Lock() xl.getDisks = func() []StorageAPI { for i := range erasureDisks[:8] { erasureDisks[i] = nil } return erasureDisks } z.serverPools[0].erasureDisksMu.Unlock() t.Run("if-none-match with read quorum failure", func(t *testing.T) { // Test Case 1: if-none-match (create only if doesn't exist) // With if-none-match: *, this should only succeed if object doesn't exist.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Oct 24 04:05:31 GMT 2025 - 4.9K bytes - Click Count (0) -
docs/resiliency/resiliency-initial-script.sh
./mc ready "${ALIAS_NAME}" ./mc mb "${ALIAS_NAME}"/"${BUCKET}" rm -rf "${SRC_DIR}" "${INLINED_DIR}" "${DEST_DIR}" && mkdir -p "${SRC_DIR}" "${INLINED_DIR}" "${DEST_DIR}" for idx in {1..10}; do # generate random nr of blocks COUNT=$((RANDOM % 100 + 100)) # generate random content dd if=/dev/urandom bs=50K count="${COUNT}" of="${SRC_DIR}"/file"$idx" done # create small object that will be inlined into xl.meta
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sat Dec 21 04:24:45 GMT 2024 - 1.5K bytes - Click Count (0) -
docs/es/docs/_llm-test.md
//// //// tab | Info Las pestañas y los bloques `Info`/`Note`/`Warning`/etc. deben tener la traducción de su título añadida después de una barra vertical (`|`). Consulta las secciones `### Special blocks` y `### Tab blocks` en el prompt general en `scripts/translate.py`. //// ## Enlaces web e internos { #web-and-internal-links } //// tab | Prueba
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 19 18:15:55 GMT 2026 - 12.2K bytes - Click Count (0)