| /third_party/rust/crates/tracing/tracing-futures/ |
| D | Cargo.toml | 2 name = "tracing-futures"
10 Utilities for instrumenting `futures` with `tracing`.
17 keywords = ["logging", "profiling", "tracing", "futures", "async"]
23 futures-01 = ["futures_01", "std"]
24 futures-03 = ["std-future", "futures", "futures-task", "std"]
30 futures_01 = { package = "futures", version = "0.1.31", optional = true }
31 futures = { version = "0.3.21", optional = true }
32 futures-task = { version = "0.3.21", optional = true }
|
| D | README.md | 5 # tracing-futures
7 Utilities for instrumenting futures-based code with [`tracing`].
19 [crates-badge]: https://img.shields.io/crates/v/tracing-futures.svg
20 [crates-url]: https://crates.io/crates/tracing-futures/0.2.5
21 [docs-badge]: https://docs.rs/tracing-futures/badge.svg
22 [docs-url]: https://docs.rs/tracing-futures/0.2.5/tracing_futures
37 for using `tracing` to instrument asynchronous code written using futures and
48 [`Instrument`]: https://docs.rs/tracing-futures/0.2.5/tracing_futures/trait.Instrument.html
49 [`WithSubscriber`]: https://docs.rs/tracing-futures/0.2.5/tracing_futures/trait.WithSubscriber.html
|
| D | CHANGELOG.md | 41 - Support for `futures` 0.3 `Stream`s and `Sink`s (#544)
45 - Compilation errors when using the `futures-03` feature (#576)
61 Compatibility with futures v0.1 is available via the `futures-01` feature.
|
| /third_party/python/Lib/test/ |
| D | test_concurrent_futures.py | 24 from concurrent import futures
25 from concurrent.futures._base import (
28 from concurrent.futures.process import BrokenProcessPool, _check_system_limits
147 futures = [self.executor.submit(time.sleep, 0.1)
149 for f in futures:
154 executor_type = futures.ThreadPoolExecutor
158 executor_type = futures.ProcessPoolExecutor
172 executor_type = futures.ProcessPoolExecutor
184 executor_type = futures.ProcessPoolExecutor
228 futures = [self.executor.submit(get_init_status)
[all …]
|
| /third_party/rust/crates/signal-hook/ |
| D | Cargo.lock | 23 "futures-core",
35 "futures-lite",
51 "futures-lite",
62 "futures-lite",
95 "futures-channel",
96 "futures-core",
97 "futures-io",
98 "futures-lite",
108 "wasm-bindgen-futures",
145 "futures-lite",
[all …]
|
| /third_party/python/Doc/library/ |
| D | concurrent.futures.rst | 1 :mod:`concurrent.futures` --- Launching parallel tasks
4 .. module:: concurrent.futures
9 **Source code:** :source:`Lib/concurrent/futures/thread.py`
10 and :source:`Lib/concurrent/futures/process.py`
14 The :mod:`concurrent.futures` module provides a high-level interface for
50 The returned iterator raises a :exc:`concurrent.futures.TimeoutError`
73 when the currently pending futures are done executing. Calls to
78 pending futures are done executing and the resources associated with the
81 freed when all pending futures are done executing. Regardless of the
83 pending futures are done executing.
[all …]
|
| D | asyncio-future.rst | 4 .. _asyncio-futures:
10 **Source code:** :source:`Lib/asyncio/futures.py`,
70 Wrap a :class:`concurrent.futures.Future` object in a
257 :class:`concurrent.futures.Future`. Key differences include:
259 - unlike asyncio Futures, :class:`concurrent.futures.Future`
274 :func:`concurrent.futures.wait` and
275 :func:`concurrent.futures.as_completed` functions.
278 but :func:`concurrent.futures.cancel` does not.
|
| /third_party/python/Lib/asyncio/ |
| D | tasks.py | 12 import concurrent.futures
25 from . import futures
61 if futures._get_loop(t) is loop and not t.done()}
74 class Task(futures._PyFuture): # Inherit Python Task implementation
116 if self._state == futures._PENDING and self._log_destroy_pending:
255 if futures._get_loop(result) is not self._loop:
344 FIRST_COMPLETED = concurrent.futures.FIRST_COMPLETED
345 FIRST_EXCEPTION = concurrent.futures.FIRST_EXCEPTION
346 ALL_COMPLETED = concurrent.futures.ALL_COMPLETED
365 if futures.isfuture(fs) or coroutines.iscoroutine(fs):
[all …]
|
| D | __main__.py | 4 import concurrent.futures
11 from . import futures
23 future = concurrent.futures.Future()
51 futures._chain_future(repl_future, future)
|
| D | futures.py | 7 import concurrent.futures
317 if exc_class is concurrent.futures.CancelledError:
319 elif exc_class is concurrent.futures.TimeoutError:
321 elif exc_class is concurrent.futures.InvalidStateError:
370 concurrent.futures.Future):
373 concurrent.futures.Future):
408 assert isinstance(future, concurrent.futures.Future), \
|
| D | __init__.py | 12 from .futures import *
27 futures.__all__ +
|
| /third_party/rust/crates/signal-hook/signal-hook-tokio/ |
| D | Cargo.toml | 23 futures-v0_3 = ["futures-core-0_3"]
28 futures-core-0_3 = { package = "futures-core", version = "~0.3", optional = true }
33 futures = "~0.3"
|
| /third_party/python/Lib/test/test_asyncio/ |
| D | test_futures.py | 3 import concurrent.futures
12 from asyncio import futures
377 from asyncio.futures import _copy_future_state
478 ex = concurrent.futures.ThreadPoolExecutor(1)
495 ex = concurrent.futures.ThreadPoolExecutor(1)
506 ex = concurrent.futures.ThreadPoolExecutor(1)
520 ex = concurrent.futures.ThreadPoolExecutor(1)
529 f1 = concurrent.futures.Future()
537 f1 = concurrent.futures.Future()
593 futures._set_result_unless_cancelled(fut, 2)
[all …]
|
| /third_party/rust/crates/cxx/book/src/ |
| D | async.md | 28 channel (such as [`futures::channel::oneshot`]) represented in an opaque Rust
31 [`futures::channel::oneshot`]: https://docs.rs/futures/0.3.8/futures/channel/oneshot/index.html
36 use futures::channel::oneshot;
|
| /third_party/rust/crates/tracing/examples/ |
| D | Cargo.toml | 20 tracing-futures = { version = "0.2.1", path = "../tracing-futures", features = ["futures-01"] }
31 futures = "0.3.21"
|
| D | README.md | 47 - **tracing-futures**:
53 + `futures-proxy-server`: Demonstrates the use of `tracing-futures` by
|
| /third_party/rust/crates/tracing/tracing-futures/src/ |
| D | lib.rs | 344 impl<T: futures::Stream> futures::Stream for Instrumented<T> {
350 ) -> futures::task::Poll<Option<Self::Item>> { in poll_next()
359 impl<I, T: futures::Sink<I>> futures::Sink<I> for Instrumented<T>
361 T: futures::Sink<I>,
368 ) -> futures::task::Poll<Result<(), Self::Error>> { in poll_ready()
383 ) -> futures::task::Poll<Result<(), Self::Error>> { in poll_flush()
392 ) -> futures::task::Poll<Result<(), Self::Error>> { in poll_close()
663 use futures::{future, sink, stream, FutureExt, SinkExt, StreamExt};
|
| /third_party/rust/crates/tracing/tracing-tower/ |
| D | Cargo.toml | 29 tracing-futures = { version = "0.2.1", path = "../tracing-futures", features = ["std-future"] }
30 futures = "0.3.21"
|
| /third_party/flutter/flutter/packages/flutter_tools/lib/src/ |
| D | run_hot.dart | 325 final List<Future<void>> futures = <Future<void>>[];
330 futures.add(device.devFS.destroy()
338 await Future.wait(futures);
347 final List<Future<void>> futures = <Future<void>>[];
349 futures.add(view.runFromSource(entryUri, packagesUri, assetsDirectoryUri));
351 Future.wait(futures).whenComplete(() { completer.complete(null); });
357 final List<Future<void>> futures = <Future<void>>[];
364 futures.add(_launchInView(device,
369 await Future.wait(futures);
371 futures.clear();
[all …]
|
| D | resident_runner.dart | 138 final List<Future<void>> futures = <Future<void>>[];
140 futures.add(service.vm.refreshViews(waitForViews: true));
141 await Future.wait(futures);
173 final List<Future<void>> futures = <Future<void>>[];
188 futures.add(view.uiIsolate.flutterExit());
194 await Future.wait(futures).timeout(const Duration(seconds: 2), onTimeout: () => <void>[]);
647 final List<Future<void>> futures = <Future<void>>[];
649 futures.add(device.refreshViews());
650 await Future.wait(futures);
812 // futures either because they just print to logger and is not critical.
[all …]
|
| /third_party/python/Lib/test/test_importlib/partial/ |
| D | cfimport.py | 13 from concurrent.futures import ThreadPoolExecutor
20 from concurrent.futures.thread import ThreadPoolExecutor
|
| /third_party/rust/crates/tracing/.cargo/ |
| D | audit.toml | 7 # be updated, so as long as `tracing-futures` supports tokio 0.1, we can't
13 # TODO: when `tracing-futures` drops support for `tokio` 0.1, we can remove
|
| /third_party/python/Lib/concurrent/futures/ |
| D | _base.py | 146 def __init__(self, futures): argument
147 self.futures = sorted(futures, key=id)
150 for future in self.futures:
154 for future in self.futures:
|
| /third_party/cef/tools/yapf/yapf/ |
| D | __init__.py | 223 import concurrent.futures # pylint: disable=g-import-not-at-top
225 with concurrent.futures.ProcessPoolExecutor(workers) as executor:
231 for future in concurrent.futures.as_completed(future_formats):
|
| /third_party/rust/crates/tracing/tracing-subscriber/ |
| D | Cargo.toml | 78 tracing-futures = { path = "../tracing-futures", version = "0.2.0", default-features = false, featu…
|