Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 111 - 120 of 682 for blocks (0.05 seconds)

  1. guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

      private static final long SMALL_TIMEOUT_MILLIS = 10;
    
      /** How long to wait when determining that a thread is blocked if we expect it to be blocked. */
      private static final long EXPECTED_HANG_DELAY_MILLIS = 75;
    
      /**
       * How long to wait when determining that a thread is blocked if we DON'T expect it to be blocked.
       */
      private static final long UNEXPECTED_HANG_DELAY_MILLIS = 10000;
    
      /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 26.7K bytes
    - Click Count (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

      private static final long SMALL_TIMEOUT_MILLIS = 10;
    
      /** How long to wait when determining that a thread is blocked if we expect it to be blocked. */
      private static final long EXPECTED_HANG_DELAY_MILLIS = 75;
    
      /**
       * How long to wait when determining that a thread is blocked if we DON'T expect it to be blocked.
       */
      private static final long UNEXPECTED_HANG_DELAY_MILLIS = 10000;
    
      /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 26.7K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/util/concurrent/RateLimiter.java

    import java.util.Locale;
    import java.util.concurrent.TimeUnit;
    import org.jspecify.annotations.Nullable;
    
    /**
     * A rate limiter. Conceptually, a rate limiter distributes permits at a configurable rate. Each
     * {@link #acquire()} blocks if necessary until a permit is available, and then takes it. Once
     * acquired, permits need not be released.
     *
     * <p>{@code RateLimiter} is safe for concurrent use: It will restrict the total rate of calls from
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Dec 26 20:05:27 GMT 2025
    - 21.8K bytes
    - Click Count (0)
  4. scripts/tests/test_translation_fixer/test_complex_doc/data/translated_doc_expected.md

    Следующие блоки кода содержат комментарии в разных стилях в зависимости от языка.
    Инструмент исправления не будет сохранять комментарии в этих блоках.
    
    ```json
    {
        # This is a sample JSON code block
        "greeting": "Hello, world!" # Print greeting
    }
    ```
    
    ```console
    # This is a sample console code block
    $ echo "Hello, world!"  # Print greeting
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Tue Feb 17 08:08:04 GMT 2026
    - 10.9K bytes
    - Click Count (0)
  5. src/test/java/jcifs/internal/fscc/FileFsFullSizeInformationTest.java

            @Test
            @DisplayName("Should handle typical Linux ext4 configuration")
            void shouldHandleTypicalExt4Configuration() throws SMBProtocolDecodingException {
                // Given - typical ext4: 4KB blocks
                long totalBlocks = 26214400L; // 100GB / 4KB
                long freeBlocks = 5242880L; // 20GB / 4KB
    
                ByteBuffer buffer = ByteBuffer.allocate(32);
                buffer.order(ByteOrder.LITTLE_ENDIAN);
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 30.5K bytes
    - Click Count (0)
  6. src/archive/tar/reader_test.go

    		// Write the initial GNU header.
    		var blk block
    		gnu := blk.toGNU()
    		sparse := gnu.sparse()
    		copy(gnu.realSize(), size)
    		sps = populateSparseMap(sparse, sps)
    		if format != FormatUnknown {
    			blk.setFormat(format)
    		}
    		out = append(out, blk[:]...)
    
    		// Write extended sparse blocks.
    		for len(sps) > 0 {
    			var blk block
    			sps = populateSparseMap(blk.toSparse(), sps)
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Tue Dec 30 15:28:53 GMT 2025
    - 47.5K bytes
    - Click Count (0)
  7. src/archive/tar/writer.go

    					sa.IsExtended()[0] = 1
    				}
    				return sp
    			}
    			sp2 := formatSPD(spd, blk.GNU().Sparse())
    			for len(sp2) > 0 {
    				var spHdr block
    				sp2 = formatSPD(sp2, spHdr.Sparse())
    				spb = append(spb, spHdr[:]...)
    			}
    
    			// Update size fields in the header block.
    			realSize := hdr.Size
    			hdr.Size = 0 // Encoded size; does not account for encoded sparse map
    			for _, s := range spd {
    				hdr.Size += s.Length
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Mon Feb 03 16:38:43 GMT 2025
    - 19.7K bytes
    - Click Count (0)
  8. scripts/tests/test_translation_fixer/test_complex_doc/data/translated_doc.md

    # Тестовый инструмент исправления переводов { #test-translation-fixer }
    
    ## Блоки кода с комментариями и без комментариев { #code-blocks-with-and-without-comments }
    
    Это тестовая страница для инструмента исправления переводов.
    
    ### Блоки кода с комментариями { #code-blocks-with-comments }
    
    Следующие блоки кода содержат комментарии в разных стилях.
    Инструмент исправления должен исправлять содержимое, но корректно сохранять комментарии.
    
    ```python
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Tue Feb 17 08:08:04 GMT 2026
    - 11.2K bytes
    - Click Count (0)
  9. cmd/erasure-server-pool.go

    				go func() {
    					defer wg.Done()
    					for info := range updates {
    						mu.Lock()
    						results[i] = info
    						mu.Unlock()
    					}
    				}()
    				// Start scanner. Blocks until done.
    				err := erObj.nsScanner(ctx, allBuckets, wantCycle, updates, healScanMode)
    				if err != nil {
    					scannerLogIf(ctx, err)
    					mu.Lock()
    					if firstErr == nil {
    						firstErr = err
    					}
    					// Cancel remaining...
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 89.2K bytes
    - Click Count (0)
  10. mockwebserver/src/test/java/mockwebserver3/MockWebServerTest.kt

        assertThat(first.requestLine).isEqualTo("GET / HTTP/1.1")
        val redirect = server.takeRequest()
        assertThat(redirect.requestLine).isEqualTo("GET /new-path HTTP/1.1")
      }
    
      /**
       * Test that MockWebServer blocks for a call to enqueue() if a request is made before a mock
       * response is ready.
       */
      @Test
      fun dispatchBlocksWaitingForEnqueue() {
        Thread {
          try {
            Thread.sleep(1000)
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Aug 03 22:38:00 GMT 2025
    - 28K bytes
    - Click Count (0)
Back to Top