- Sort Score
- Result 10 results
- Languages All
Results 191 - 200 of 601 for Block (0.18 sec)
-
guava/src/com/google/common/util/concurrent/ExecutionList.java
// is likely to be a bug anyway. // N.B. All writes to the list and the next pointers must have happened before the above // synchronized block, so we can iterate the list without the lock held here. RunnableExecutorPair reversedList = null; while (list != null) { RunnableExecutorPair tmp = list; list = list.next; tmp.next = reversedList;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 6.9K bytes - Viewed (0) -
docs/en/docs/tutorial/dependencies/dependencies-with-yield.md
**FastAPI** will do the right thing with each, the same as with normal dependencies. /// ## A dependency with `yield` and `try` { #a-dependency-with-yield-and-try } If you use a `try` block in a dependency with `yield`, you'll receive any exception that was thrown when using the dependency.
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sun Aug 31 09:15:41 UTC 2025 - 12.7K bytes - Viewed (0) -
compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/DefaultUpdateCheckManager.java
return; } FileChannel channel = null; FileLock lock = null; try { Properties props = new Properties(); channel = new RandomAccessFile(touchfile, "rw").getChannel(); lock = channel.lock(); if (touchfile.canRead()) {
Registered: Sun Sep 07 03:35:12 UTC 2025 - Last Modified: Tue Apr 22 22:13:51 UTC 2025 - 12.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/IoTestCase.java
} catch (Exception ignore) { // probably URISyntaxException or IllegalArgumentException // fall back to copying URLs to files in the testDir == null block below } } if (testDir == null) { // testdata resources aren't file:// urls, so create a directory to store them in and then // copy the resources to the filesystem as needed
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 5.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AggregateFutureStateFallbackAtomicHelperTest.java
for (Method method : FuturesTest.class.getDeclaredMethods()) { if (Modifier.isPublic(method.getModifiers()) && method.getName().startsWith("test") /* * When we block access to AtomicReferenceFieldUpdater, we can't even reflect on * AbstractFuture, since it declares methods that use that type in their signatures. */
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 18:46:00 UTC 2025 - 6.5K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/ServerMessageBlock2.java
private ServerMessageBlock2 next; /** * Constructor for SMB2 message block with configuration. * * @param config the configuration object */ protected ServerMessageBlock2(final Configuration config) { this.config = config; } /** * Constructor for SMB2 message block with configuration and command. * * @param config the configuration object
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 24K bytes - Viewed (0) -
cmd/metacache.go
// Max time between client calls before dropping an async cache listing. metacacheMaxClientWait = 3 * time.Minute // metacacheBlockSize is the number of file/directory entries to have in each block. metacacheBlockSize = 5000 // metacacheSharePrefix controls whether prefixes on dirty paths are always shared. // This will make `test/a` and `test/b` share listings if they are concurrent.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Jul 12 16:23:16 UTC 2024 - 6K bytes - Viewed (0) -
finisher_api.go
// Make sure to rollback when panic, Block error or Commit error if panicked || err != nil { db.RollbackTo(fmt.Sprintf("sp%d", spID)) } }() } err = fc(db.Session(&Session{NewDB: db.clone == 1})) } else { tx := db.Begin(opts...) if tx.Error != nil { return tx.Error } defer func() { // Make sure to rollback when panic, Block error or Commit error
Registered: Sun Sep 07 09:35:13 UTC 2025 - Last Modified: Tue Aug 26 06:24:29 UTC 2025 - 22.9K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2ExchangeCodec.kt
headers.value(i) == "trailers" ) { result.add(Header(name, headers.value(i))) } } return result } /** Returns headers for a name value block containing an HTTP/2 response. */ fun readHttp2HeadersList( headerBlock: Headers, protocol: Protocol, ): Response.Builder { var statusLine: StatusLine? = null
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue Jul 29 21:11:09 UTC 2025 - 7K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Tables.java
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Jul 17 15:26:41 UTC 2025 - 24.9K bytes - Viewed (0)