- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 321 for Sync (0.15 sec)
-
tests/test_dependency_contextmanager.py
tasks.add_task(bg, state) return state # Sync versions @app.get("/sync_async") def get_sync_async(state: str = Depends(asyncgen_state)): return state @app.get("/sync_sync") def get_sync_sync(state: str = Depends(generator_state)): return state @app.get("/sync_async_raise") def get_sync_async_raise(state: str = Depends(asyncgen_state_try)):
Python - Registered: Sun Apr 28 07:19:10 GMT 2024 - Last Modified: Sat Feb 24 23:06:37 GMT 2024 - 11.6K bytes - Viewed (0) -
api/go1.19.txt
pkg sync/atomic, method (*Uintptr) Load() uintptr #50860 pkg sync/atomic, method (*Uintptr) Store(uintptr) #50860 pkg sync/atomic, method (*Uintptr) Swap(uintptr) uintptr #50860 pkg sync/atomic, type Bool struct #50860 pkg sync/atomic, type Int32 struct #50860 pkg sync/atomic, type Int64 struct #50860 pkg sync/atomic, type Pointer[$0 interface{}] struct #50860 pkg sync/atomic, type Uint32 struct #50860
Plain Text - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Dec 02 16:29:41 GMT 2022 - 17.9K bytes - Viewed (1) -
src/archive/zip/register.go
type Decompressor func(r io.Reader) io.ReadCloser var flateWriterPool sync.Pool func newFlateWriter(w io.Writer) io.WriteCloser { fw, ok := flateWriterPool.Get().(*flate.Writer) if ok { fw.Reset(w) } else { fw, _ = flate.NewWriter(w, 5) } return &pooledFlateWriter{fw: fw} } type pooledFlateWriter struct { mu sync.Mutex // guards Close and Write fw *flate.Writer }
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Oct 13 18:36:46 GMT 2023 - 3.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
return sync.get(); } @Override public boolean isDone() { return sync.isDone(); } @Override public boolean isCancelled() { return sync.isCancelled(); } @CanIgnoreReturnValue @Override public boolean cancel(boolean mayInterruptIfRunning) { if (!sync.cancel(mayInterruptIfRunning)) {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Apr 06 12:56:11 GMT 2023 - 13.6K bytes - Viewed (0) -
internal/config/lambda/target/lazyinit.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package target import ( "sync" "sync/atomic" ) // Inspired from Golang sync.Once but it is only marked // initialized when the provided function returns nil. type lazyInit struct { done uint32 m sync.Mutex } func (l *lazyInit) Do(f func() error) error { if atomic.LoadUint32(&l.done) == 0 { return l.doSlow(f)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Mar 07 16:12:41 GMT 2023 - 1.3K bytes - Viewed (0) -
internal/once/init.go
package once import ( "context" "sync" "sync/atomic" ) // Inspired from Golang sync.Once but it is only marked // initialized when the provided function returns nil. // Init represents the structure. type Init struct { done uint32 m sync.Mutex } // Do is similar to sync.Once.Do - makes one successful // call to the function. ie, it invokes the function
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue May 09 04:20:31 GMT 2023 - 2.1K bytes - Viewed (0) -
scripts/playwright/separate_openapi_schemas/image04.py
import subprocess from playwright.sync_api import Playwright, sync_playwright def run(playwright: Playwright) -> None: browser = playwright.chromium.launch(headless=False) context = browser.new_context(viewport={"width": 960, "height": 1080}) page = context.new_page() page.goto("http://localhost:8000/docs") page.get_by_role("button", name="Item-Input").click() page.get_by_role("button", name="Item-Output").click()
Python - Registered: Sun Apr 28 07:19:10 GMT 2024 - Last Modified: Fri Aug 25 19:10:22 GMT 2023 - 881 bytes - Viewed (0) -
internal/event/targetlist.go
func (list *TargetList) Send(event Event, targetIDset TargetIDSet, sync bool) { if sync { list.sendSync(event, targetIDset) } else { list.sendAsync(event, targetIDset) } } func (list *TargetList) sendSync(event Event, targetIDset TargetIDSet) { var wg sync.WaitGroup for id := range targetIDset { target, ok := list.get(id) if !ok { continue }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.2K bytes - Viewed (0) -
scripts/playwright/separate_openapi_schemas/image02.py
import subprocess from playwright.sync_api import Playwright, sync_playwright def run(playwright: Playwright) -> None: browser = playwright.chromium.launch(headless=False) context = browser.new_context(viewport={"width": 960, "height": 1080}) page = context.new_page() page.goto("http://localhost:8000/docs") page.get_by_text("GET/items/Read Items").click() page.get_by_role("button", name="Try it out").click()
Python - Registered: Sun Apr 28 07:19:10 GMT 2024 - Last Modified: Fri Aug 25 19:10:22 GMT 2023 - 873 bytes - Viewed (0) -
docs/bucket/replication/setup_3site_replication.sh
--replicate "existing-objects,delete,delete-marker,replica-metadata-sync" sleep 1 echo "adding replication rule for b -> a : ${remote_arn}" ./mc replicate add siteb/bucket/ \ --remote-bucket http://minio:minio123@127.0.0.1:9001/bucket \ --replicate "existing-objects,delete,delete-marker,replica-metadata-sync" sleep 1 echo "adding replication rule for a -> c : ${remote_arn}"
Shell Script - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 10.2K bytes - Viewed (0)