Search Options

Results per page
Sort
Preferred Languages
Advance

Results 381 - 390 of 507 for kwait (0.03 sec)

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

        assertSame(exception, e.getCause());
      }
    
      private static void awaitUnchecked(CyclicBarrier barrier) {
        try {
          barrier.await();
        } catch (Exception e) {
          throw new RuntimeException(e);
        }
      }
    
      private void checkStackTrace(ExecutionException e) {
        // Our call site for get() should be in the trace.
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 46.8K bytes
    - Viewed (0)
  2. docs/de/docs/advanced/custom-response.md

    /// tip | Tipp
    
    Beachten Sie, dass wir, da wir Standard-`open()` verwenden, welches `async` und `await` nicht unterstützt, hier die Pfadoperation mit normalen `def` deklarieren.
    
    ///
    
    ### `FileResponse`
    
    Streamt eine Datei asynchron als Response.
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Mon Nov 18 02:25:44 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  3. docs/yo/docs/index.md

    def read_item(item_id: int, q: Union[str, None] = None):
        return {"item_id": item_id, "q": q}
    ```
    
    <details markdown="1">
    <summary>Tàbí lò <code>async def</code>...</summary>
    
    Tí kóòdù rẹ̀ bá ń lò `async` / `await`, lò `async def`:
    
    ```Python hl_lines="9  14"
    from typing import Union
    
    from fastapi import FastAPI
    
    app = FastAPI()
    
    
    @app.get("/")
    async def read_root():
        return {"Hello": "World"}
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Aug 31 10:49:48 UTC 2025
    - 24.1K bytes
    - Viewed (0)
  4. cmd/data-usage-cache.go

    	*d = dataUsageCache{}
    
    	load := func(name string, timeout time.Duration) (bool, error) {
    		// Abandon if more than time.Minute, so we don't hold up scanner.
    		// drive timeout by default is 2 minutes, we do not need to wait longer.
    		ctx, cancel := context.WithTimeout(ctx, timeout)
    		defer cancel()
    
    		r, err := store.GetObjectNInfo(ctx, minioMetaBucket, pathJoin(bucketMetaPrefix, name), nil, http.Header{}, ObjectOptions{NoLock: true})
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 34.7K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/cache/Cache.java

       * value. Otherwise, a call that passes one {@code loader} may return the result of another call
       * with a differently behaving {@code loader}. For example, a call that requests a short timeout
       * for an RPC may wait for a similar call that requests a long timeout, or a call by an
       * unprivileged user may return a resource accessible only to a privileged user making a similar
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  6. apache-maven/src/assembly/maven/bin/mvn.cmd

    @REM   MAVEN_ARGS        (Optional) Arguments passed to Maven before CLI arguments.
    @REM   MAVEN_BATCH_ECHO  (Optional) Set to 'on' to enable the echoing of the batch commands.
    @REM   MAVEN_BATCH_PAUSE (Optional) set to 'on' to wait for a key stroke before ending.
    @REM   MAVEN_OPTS        (Optional) Java runtime options used when Maven is executed.
    @REM   MAVEN_SKIP_RC     (Optional) Flag to disable loading of mavenrc files.
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Thu Jul 24 09:49:07 UTC 2025
    - 9.6K bytes
    - Viewed (3)
  7. cmd/erasure-decode.go

    			newBuf[bufIdx] = p.buf[bufIdx][:n]
    			newBufLK.Unlock()
    			// Since ReadAt returned success, there is no need to trigger another read.
    			readTriggerCh <- false
    		}(readerIndex)
    		readerIndex++
    	}
    	wg.Wait()
    	if p.canDecode(newBuf) {
    		p.offset += p.shardSize
    		if missingPartsHeal == 1 {
    			return newBuf, errFileNotFound
    		} else if bitrotHeal == 1 {
    			return newBuf, errFileCorrupt
    		}
    		return newBuf, nil
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Aug 29 01:40:52 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  8. src/test/java/org/codelibs/fess/ds/callback/IndexUpdateCallbackImplTest.java

                            // Log error
                        }
                    }
                });
                threads.add(thread);
                thread.start();
            }
    
            // Wait for all threads
            for (Thread thread : threads) {
                thread.join();
            }
    
            // Verify all documents were processed
            assertEquals(threadCount * docsPerThread, successCount.get());
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 24.5K bytes
    - Viewed (0)
  9. tests/preload_test.go

    			defer wg.Done()
    			var user2 []User
    			tx := DB.Where("id = ?", 1).Session(&gorm.Session{})
    
    			if err := tx.Preload("Team").Find(&user2).Error; err != nil {
    				t.Error(err)
    			}
    		}()
    	}
    	wg.Wait()
    }
    
    func TestPreloadWithDiffModel(t *testing.T) {
    	user := *GetUser("preload_with_diff_model", Config{Account: true})
    
    	if err := DB.Create(&user).Error; err != nil {
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Wed Jun 12 10:00:47 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  10. compat/maven-compat/src/main/java/org/apache/maven/artifact/resolver/DefaultArtifactResolver.java

                    } else {
                        latch.countDown();
                    }
                }
                try {
                    latch.await();
                } catch (InterruptedException e) {
                    result.addErrorArtifactException(
                            new ArtifactResolutionException("Resolution interrupted", rootArtifact, e));
                }
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Fri Jun 06 14:28:57 UTC 2025
    - 25K bytes
    - Viewed (0)
Back to top