Search Options

Results per page
Sort
Preferred Languages
Advance

Results 381 - 390 of 627 for nwait (0.03 sec)

  1. build-logic/cleanup/src/main/java/gradlebuild/cleanup/services/KillLeakingJavaProcesses.java

                ByteArrayOutputStream stderr = connectStream(process.getErrorStream(), latch);
    
                process.waitFor(1, TimeUnit.MINUTES);
                latch.await(1, TimeUnit.MINUTES);
                return new ExecResult(args, process.exitValue(), stdout.toString(), stderr.toString());
            } catch (Exception e) {
                throw new RuntimeException(e);
            }
        }
    
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Mon Aug 19 15:07:24 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

      }
    
      /** A typical timeout value we'll use in the tests. */
      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.
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 27.1K bytes
    - Viewed (0)
  3. internal/kms/kes.go

    				item = madmin.ItemOnline
    			} else {
    				item = madmin.ItemOffline
    			}
    			results[i] = Result{
    				Endpoint:  c.client.Endpoints[i],
    				ItemState: item,
    			}
    		}(i)
    	}
    	wg.Wait()
    
    	status := make(map[string]madmin.ItemState, len(results))
    	for _, r := range results {
    		if r.ItemState == madmin.ItemOnline {
    			status[r.Endpoint] = madmin.ItemOnline
    		} else {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Aug 18 06:43:03 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  4. docs/de/docs/index.md

        return {"item_id": item_id, "q": q}
    ```
    
    <details markdown="1">
    <summary>Oder verwenden Sie <code>async def</code> ...</summary>
    
    Wenn Ihr Code `async` / `await` verwendet, benutzen Sie `async def`:
    
    ```Python hl_lines="9  14"
    from typing import Union
    
    from fastapi import FastAPI
    
    app = FastAPI()
    
    
    @app.get("/")
    async def read_root():
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 20 19:20:23 UTC 2024
    - 21.1K bytes
    - Viewed (0)
  5. docs/it/docs/index.md

    def read_item(item_id: int, q: str = Optional[None]):
        return {"item_id": item_id, "q": q}
    ```
    
    <details markdown="1">
    <summary>Oppure usa <code>async def</code>...</summary>
    
    Se il tuo codice usa `async` / `await`, allora usa `async def`:
    
    ```Python hl_lines="7  12"
    from fastapi import FastAPI
    from typing import Optional
    
    app = FastAPI()
    
    
    @app.get("/")
    async def read_root():
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 20 19:20:23 UTC 2024
    - 19.2K bytes
    - Viewed (0)
  6. src/main/java/jcifs/smb/SmbPipeHandleImpl.java

                        this.handle = this.pipe.openUnshared(this.uncPath, 0, this.access, this.sharing, SmbConstants.ATTR_NORMAL, 0);
                        return this.handle.acquire();
                    }
    
                    // TODO: wait for pipe, still not sure when this needs to be called exactly
                    if ( this.uncPath.startsWith("\\pipe\\") ) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Mon Apr 13 17:05:22 UTC 2020
    - 10.3K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/internal/publicsuffix/PublicSuffixDatabase.kt

        if (!listRead.get() && listRead.compareAndSet(false, true)) {
          readTheListUninterruptibly()
        } else {
          try {
            readCompleteLatch.await()
          } catch (_: InterruptedException) {
            Thread.currentThread().interrupt() // Retain interrupted status.
          }
        }
    
        check(::publicSuffixListBytes.isInitialized) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/base/FinalizableReferenceQueueClassLoaderUnloadingTest.java

            new AtomicReference<WeakReference<?>>(
                (WeakReference<?>) sepFwrCons.newInstance(sepStopwatchA.get(), sepFrqA.get()));
        assertNotNull(sepStopwatchA.get());
        // Clear all references to the Stopwatch and wait for it to be gc'd.
        sepStopwatchA.set(null);
        GcFinalization.awaitClear(sepStopwatchRef.get());
        // Return a weak reference to the parallel ClassLoader. This is the reference that should
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  9. docs/fr/docs/index.md

        return {"item_id": item_id, "q": q}
    ```
    
    <details markdown="1">
    <summary>Ou utilisez <code>async def</code> ...</summary>
    
    Si votre code utilise `async` / `await`, utilisez `async def` :
    
    ```Python hl_lines="9  14"
    from typing import Union
    
    from fastapi import FastAPI
    
    app = FastAPI()
    
    
    @app.get("/")
    async def read_root():
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 20 19:20:23 UTC 2024
    - 22K bytes
    - Viewed (0)
  10. docs/zh-hant/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>或可以使用 <code>async def</code>...</summary>
    
    如果你的程式使用 `async` / `await`,請使用 `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 Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 20 19:20:23 UTC 2024
    - 18.8K bytes
    - Viewed (0)
Back to top