Search Options

Results per page
Sort
Preferred Languages
Advance

Results 181 - 190 of 682 for Clock (0.04 sec)

  1. 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)
  2. guava/src/com/google/common/util/concurrent/Striped.java

         * error-prone code like:
         *
         * Striped<Lock> stripedLock = Striped.lazyWeakXXX(...)'
         * Iterable<Lock> locks = stripedLock.bulkGet(keys);
         * for (Lock lock : locks) {
         *   lock.lock();
         * }
         * operation();
         * for (Lock lock : locks) {
         *   lock.unlock();
         * }
         *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Jun 26 12:58:35 UTC 2024
    - 20.6K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top