Search Options

Results per page
Sort
Preferred Languages
Advance

Results 151 - 160 of 617 for block (0.04 sec)

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

                    return blockingCallable.isRunning();
                  }
                },
                directExecutor());
    
        // Wait for the first task to be started in the background. It will block until we explicitly
        // stop it.
        blockingCallable.waitForStart();
    
        // Give the second task a chance to (incorrectly) start up while the first task is running.
        assertThat(future2.isDone()).isFalse();
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 16.7K bytes
    - Viewed (0)
  2. src/archive/tar/common.go

    		}
    		pre = cur
    	}
    	return true
    }
    
    // alignSparseEntries mutates src and returns dst where each fragment's
    // starting offset is aligned up to the nearest block edge, and each
    // ending offset is aligned down to the nearest block edge.
    //
    // Even though the Go tar Reader and the BSD tar utility can handle entries
    // with arbitrary offsets and lengths, the GNU tar utility can only handle
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Sep 13 21:03:27 UTC 2024
    - 24.5K bytes
    - Viewed (0)
  3. internal/s3select/progress.go

    	// This ensures that Close will block until Read has completed.
    	// This allows another goroutine to close the reader.
    	pr.closedMu.Lock()
    	defer pr.closedMu.Unlock()
    	if pr.closed {
    		return 0, errors.New("progressReader: read after Close")
    	}
    	return pr.processedReader.Read(p)
    }
    
    func (pr *progressReader) Close() error {
    	pr.closedMu.Lock()
    	defer pr.closedMu.Unlock()
    	if pr.closed {
    		return nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  4. mkdocs.yml

    repo_url: https://github.com/square/okhttp
    site_description: "Square’s meticulous HTTP client for the JVM, Android, and GraalVM"
    site_author: Square, Inc.
    remote_branch: gh-pages
    edit_uri: ""
    
    copyright: 'Copyright © 2022 Block, Inc.'
    
    theme:
      name: 'material'
      favicon: assets/images/icon-square.png
      logo: assets/images/icon-square.png
      palette:
        - media: "(prefers-color-scheme: light)"
          scheme: default
          primary: teal
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Nov 20 15:26:12 UTC 2023
    - 3.8K bytes
    - Viewed (0)
  5. doc/go_spec.html

    </p>
    
    <h2 id="Blocks">Blocks</h2>
    
    <p>
    A <i>block</i> is a possibly empty sequence of declarations and statements
    within matching brace brackets.
    </p>
    
    <pre class="ebnf">
    Block = "{" StatementList "}" .
    StatementList = { Statement ";" } .
    </pre>
    
    <p>
    In addition to explicit blocks in the source code, there are implicit blocks:
    </p>
    
    <ol>
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Oct 02 00:58:01 UTC 2024
    - 282.5K bytes
    - Viewed (0)
  6. docs/logging/README.md

        "X-Amz-Id-2": "dd9025bab4ad464b049177c95eb6ebf374d3b3fd1af9251148b658df7ac2e3e8",
        "X-Amz-Request-Id": "17CDC1F4D7E69123",
        "X-Content-Type-Options": "nosniff",
        "X-Xss-Protection": "1; mode=block"
      },
      "tags": {
        "objectLocation": {
          "name": "hosts",
          "poolId": 1,
          "setId": 1,
          "drives": [
            "/mnt/data1",
            "/mnt/data2",
            "/mnt/data3",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 09 17:15:03 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  7. okhttp/src/test/java/okhttp3/internal/http/ThreadInterruptTest.kt

      private lateinit var server: MockWebServer
      private lateinit var client: OkHttpClient
    
      @BeforeEach
      fun setUp() {
        // Sockets on some platforms can have large buffers that mean writes do not block when
        // required. These socket factories explicitly set the buffer sizes on sockets created.
        server = MockWebServer()
        server.serverSocketFactory =
          object : DelegatingServerSocketFactory(getDefault()) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  8. internal/dsync/drwmutex.go

    	}
    }
    
    // Lock holds a write lock on dm.
    //
    // If the lock is already in use, the calling go routine
    // blocks until the mutex is available.
    func (dm *DRWMutex) Lock(id, source string) {
    	isReadLock := false
    	dm.lockBlocking(context.Background(), nil, id, source, isReadLock, Options{
    		Timeout: drwMutexInfinite,
    	})
    }
    
    // Options lock options.
    type Options struct {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 15:49:49 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/ResponseBody.kt

     * block. With this structure the compiler inserts an implicit `finally` clause that calls
     * [close()][Response.close] for you.
     *
     * ```java
     * Call call = client.newCall(request);
     * try (Response response = call.execute()) {
     * ... // Use the response.
     * }
     * ```
     *
     * You can use a similar block for asynchronous calls:
     *
     * ```java
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java

        assertFalse(task.isDone());
        assertFalse(task.isCancelled());
    
        // Start the task to put it in the RUNNING state.  Have to use a separate
        // thread because the task will block on the task latch after unblocking
        // the run latch.
        exec.execute(task);
        runLatch.await();
        assertEquals(1, listenerLatch.getCount());
        assertFalse(task.isDone());
        assertFalse(task.isCancelled());
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 4.7K bytes
    - Viewed (0)
Back to top