Search Options

Results per page
Sort
Preferred Languages
Advance

Results 271 - 280 of 603 for _wait (0.04 sec)

  1. internal/cachevalue/cache.go

    		if t.updating.TryLock() {
    			go func() {
    				defer t.updating.Unlock()
    				t.update(context.Background())
    			}()
    		}
    		return *v, nil
    	}
    
    	// Get lock. Either we get it or we wait for it.
    	t.updating.Lock()
    	defer t.updating.Unlock()
    
    	if time.Since(time.UnixMilli(t.lastUpdateMs.Load())) < ttl {
    		// There is a new value, release lock and return it.
    		if v = t.val.Load(); v != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 12:50:46 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  2. fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/CrawlerTest.java

                settingsBuilder.put("http.cors.allow-origin", "*");
                settingsBuilder.put("discovery.type", "single-node");
            }).build(newConfigs().clusterName(clusterName).numOfNode(1));
    
            // wait for yellow status
            runner.ensureYellow();
    
            System.setProperty(FesenClient.HTTP_ADDRESS, "localhost:" + runner.node().settings().get("http.port", "9201"));
    
            super.setUp();
    
            // logging
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  3. .teamcity/README.md

      - Select `Synchronization enabled` - `use settings from VCS` - `MyNewVcsRoot`(the one you just created) - `Settings format: Kotlin`, then `Apply`.
    - At the popup window, click `Import Settings from VCS`. Wait a few seconds. 
      - If the error says "Context Parameter 'Branch' missing", it's ok. Click into the error and add a context parameter `Branch` with value `myTestBranch`. Go back and it automatically reloads.
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Wed Mar 06 23:02:25 UTC 2024
    - 4K bytes
    - Viewed (0)
  4. docs/uk/docs/index.md

        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():
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 20 19:20:23 UTC 2024
    - 24.2K bytes
    - Viewed (0)
  5. cmd/global-heal.go

    					return
    				}
    			}
    
    			// All versions resulted in 'ObjectNotFound/VersionNotFound'
    			if versionNotFound == len(fivs.Versions) {
    				return
    			}
    
    			send(healEntryDone(entry.name))
    
    			// Wait and proceed if there are active requests
    			waitForLowHTTPReq()
    		}
    
    		// How to resolve partial results.
    		resolver := metadataResolutionParams{
    			dirQuorum: 1,
    			objQuorum: 1,
    			bucket:    bucket,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.3K bytes
    - Viewed (0)
  6. docs/zh/docs/tutorial/background-tasks.md

    **FastAPI** 会创建一个 `BackgroundTasks` 类型的对象并作为该参数传入。
    
    ## 创建一个任务函数
    
    创建要作为后台任务运行的函数。
    
    它只是一个可以接收参数的标准函数。
    
    它可以是 `async def` 或普通的 `def` 函数,**FastAPI** 知道如何正确处理。
    
    在这种情况下,任务函数将写入一个文件(模拟发送电子邮件)。
    
    由于写操作不使用 `async` 和 `await`,我们用普通的 `def` 定义函数:
    
    ```Python hl_lines="6-9"
    {!../../docs_src/background_tasks/tutorial001.py!}
    ```
    
    ## 添加后台任务
    
    在你的 *路径操作函数* 里,用 `.add_task()` 方法将任务函数传到 *后台任务* 对象中:
    
    ```Python hl_lines="14"
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 5K bytes
    - Viewed (0)
  7. cmd/admin-handlers-users-race_test.go

    				err := s.adm.RemoveUser(ctx, accessKeys[i])
    				if err != nil {
    					return err
    				}
    				c.mustNotListObjects(ctx, uClient, bucket)
    				return nil
    			}
    		}(i), i)
    	}
    	if errs := g.Wait(); len(errs) > 0 {
    		c.Fatalf("unable to remove users: %v", errs)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 28 09:06:25 UTC 2024
    - 4K bytes
    - Viewed (0)
  8. cmd/metacache-server-pool.go

    		defer wg.Done()
    		o.StopDiskAtLimit = true
    		listErr = z.listMerged(listCtx, o, filterCh)
    		o.debugln("listMerged returned with", listErr)
    	}(*o)
    
    	entries, err = filteredResults()
    	cancelList()
    	wg.Wait()
    	if listErr != nil && !errors.Is(listErr, context.Canceled) {
    		return entries, listErr
    	}
    	entries.reuse = true
    	truncated := entries.len() > o.Limit || err == nil
    	entries.truncate(o.Limit)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  9. docs/de/docs/advanced/dataclasses.md

        Wenn Sie eine Auffrischung darüber benötigen, wann welche Anwendung sinnvoll ist, lesen Sie den Abschnitt „In Eile?“ in der Dokumentation zu [`async` und `await`](../async.md#in-eile){.internal-link target=_blank}.
    
    9. Diese *Pfadoperation-Funktion* gibt keine Datenklassen zurück (obwohl dies möglich wäre), sondern eine Liste von Dictionarys mit internen Daten.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  10. docs/em/docs/tutorial/background-tasks.md

    ## ✍ 📋 🔢
    
    ✍ 🔢 🏃 🖥 📋.
    
    ⚫️ 🐩 🔢 👈 💪 📨 🔢.
    
    ⚫️ 💪 `async def` ⚖️ 😐 `def` 🔢, **FastAPI** 🔜 💭 ❔ 🍵 ⚫️ ☑.
    
    👉 💼, 📋 🔢 🔜 ✍ 📁 (⚖ 📨 📧).
    
    &amp; ✍ 🛠️ 🚫 ⚙️ `async` &amp; `await`, 👥 🔬 🔢 ⏮️ 😐 `def`:
    
    ```Python hl_lines="6-9"
    {!../../docs_src/background_tasks/tutorial001.py!}
    ```
    
    ## 🚮 🖥 📋
    
    🔘 👆 *➡ 🛠️ 🔢*, 🚶‍♀️ 👆 📋 🔢 *🖥 📋* 🎚 ⏮️ 👩‍🔬 `.add_task()`:
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 4.1K bytes
    - Viewed (0)
Back to top