- Sort Score
- Result 10 results
- Languages All
Results 181 - 190 of 682 for Clock (0.04 sec)
-
guava-tests/benchmark/com/google/common/util/concurrent/StripedBenchmark.java
import java.util.Random; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; /** A benchmark comparing the various striped implementations. */ @VmOptions({"-Xms12g", "-Xmx12g", "-d64"}) public class StripedBenchmark { private static final Supplier<Lock> LOCK_SUPPLIER = new Supplier<Lock>() { @Override public Lock get() { return new ReentrantLock(); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Dec 04 17:37:03 UTC 2017 - 4K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Striped.java
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Jun 26 12:58:35 UTC 2024 - 20.6K bytes - Viewed (0) -
docs/en/docs/css/termynal.css
text-align: center; } a[data-terminal-control] { text-align: right; display: block; color: #aebbff; } [data-ty] { display: block; line-height: 2; } [data-ty]:before { /* Set up defaults and ensure empty lines are displayed. */ content: ''; display: inline-block; vertical-align: middle; } [data-ty="input"]:before, [data-ty-prompt]:before {
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Fri Aug 09 01:42:26 UTC 2024 - 2.2K bytes - Viewed (0) -
cmd/namespace-lock_test.go
} } // Test lock race func TestNSLockRace(t *testing.T) { t.Skip("long test skip it") ctx := context.Background() for i := 0; i < 10000; i++ { nsLk := newNSLock(false) // lk1; ref=1 if !nsLk.lock(ctx, "volume", "path", "source", "opsID", false, time.Second) { t.Fatal("failed to acquire lock") } // lk2 lk2ch := make(chan struct{})
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Apr 23 18:58:53 UTC 2021 - 3.1K bytes - Viewed (0) -
build-logic-commons/basics/src/main/kotlin/gradlebuild/basics/util/KotlinSourceParser.kt
get() = PrintingMessageCollector(System.out, MessageRenderer.PLAIN_RELATIVE_PATHS, false) fun <T : Any> mapParsedKotlinFiles(vararg sourceRoots: File, block: (KtFile) -> T): List<T> = withParsedKotlinSource(sourceRoots.toList()) { ktFiles -> ktFiles.map(block) } fun parseSourceRoots(sourceRoots: List<File>, compilationClasspath: List<File>): ParsedKotlinFiles =
Registered: Wed Nov 06 11:36:14 UTC 2024 - Last Modified: Tue Oct 15 13:02:35 UTC 2024 - 3.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Writer.kt
streamId = 0, length = 0, type = TYPE_SETTINGS, flags = FLAG_ACK, ) sink.flush() } } /** * HTTP/2 only. Send a push promise header block. * * A push promise contains all the headers that pertain to a server-initiated request, and a * `promisedStreamId` to which response frames will be delivered. Push promise frames are sent as
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 11.3K bytes - Viewed (0) -
docs/debugging/xl-meta/main.go
combineShared := combineSharedBlocks[block] nextAttempt: fmt.Printf("Block %d, Base version %q. Part %d. Files %d\n", block+1, key, part, len(file)) m, err := readAndMap(file, part, block) if err != nil { return err } if exportedSizes[m.objSize] { fmt.Println("Skipping version", key, "as it has already been exported.") continue nextFile } addedFiles := 0
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 05 11:57:44 UTC 2024 - 40.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/query/QueryCommand.java
return QueryBuilders.matchPhraseQuery(f, text); } final UnicodeBlock block = UnicodeBlock.of(text.codePointAt(0)); if (block == UnicodeBlock.CJK_UNIFIED_IDEOGRAPHS // || block == UnicodeBlock.HIRAGANA // || block == UnicodeBlock.KATAKANA // || block == UnicodeBlock.HANGUL_SYLLABLES // ) { return QueryBuilders.prefixQuery(f, text);
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Fri Oct 11 21:11:58 UTC 2024 - 6.5K bytes - Viewed (0) -
internal/store/batch.go
func (b *Batch[I]) Add(item I) error { b.Lock() defer b.Unlock() if b.isFull() { if b.store == nil { return ErrBatchFull } // commit batch to store if err := b.commit(); err != nil { return err } } b.items = append(b.items, item) return nil } // Len returns the no of items in the batch func (b *Batch[_]) Len() int { b.Lock() defer b.Unlock() return len(b.items)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 2.9K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ForwardingLock.java
import java.util.concurrent.locks.Condition; import java.util.concurrent.locks.Lock; /** Forwarding wrapper around a {@code Lock}. */ @J2ktIncompatible @ElementTypesAreNonnullByDefault abstract class ForwardingLock implements Lock { abstract Lock delegate(); @Override public void lock() { delegate().lock(); } @Override public void lockInterruptibly() throws InterruptedException {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 1.5K bytes - Viewed (0)