asynchronous 相关问题

异步编程是用于推迟具有高延迟或低优先级的操作的策略，通常旨在提高软件的性能，响应性和/或可组合性。这些策略通常使用事件驱动编程和回调的某种组合来使用，并且可选地通过协同程序和/或线程来使用并发。

与 addEventListener 一起使用并手动调用它时，异步函数的行为有所不同[重复]

我试图理解 async 和 wait 关键字。我编写了一个简单的 HTML 文件和一个 JS 文件来演示它。以下是我的文件（第一个是index.html，第二个是script....

javascript html asynchronous

回答 1 投票 0

如何在 JSF 组件中监视异步/后台线程状态并获取通知

我在 Web 应用程序中创建了几个线程，并且在 JSF 页面中有一个数据表组件。我想自动更新表格以显示线程的当前状态。有预建吗

jsf asynchronous notifications refresh monitor

回答 1 投票 0

C# Selenium Chrome 从 WPF 运行异步而不阻塞主窗口

我正在尝试从 WPF 异步运行 Selenium 以检索一些信息，稍后我将在 WPF 中使用这些信息。 Selenium 正在无头运行。我正在尝试在 Window_Loaded 事件上运行它。这是...

c# wpf selenium-webdriver asynchronous async-await

回答 1 投票 0

为什么回调在 Promise 中有效，而 wait 却不行？

为什么我可以有异步代码，比如通过回调获取数据库连接，这工作得很好，但我不能在 Promises 中等待相同的代码。例如返回新的 Promise((解决, 拒绝) => {...

javascript asynchronous async-await promise

回答 1 投票 0

具有 Boxed 异步回调类型字段的结构的生命周期必须比“static”长

{ f: 盒子销钉我有这个最小的例子： use std::{future::Future, pin::Pin, thread::JoinHandle, fmt::Debug}; use tokio::runtime::Runtime; struct Callback<E> { f: Box<dyn Fn() -> Pin<Box<dyn Future<Output = Result<(), E>> + Send + Sync>> + Send + Sync>, } trait Provider { fn setup(&self) -> JoinHandle<()>; } enum Foo { A, B } trait IntoFoo { fn into_foo(&self) -> Foo; } impl<E: Debug + IntoFoo> Provider for Callback<E> { fn setup(&self) -> JoinHandle<()> { std::thread::spawn(move || { // Running async function sycnhronously within another thread. let rt = Runtime::new().unwrap(); rt.block_on(handle(Box::new(move || (self.f)()))) .expect("request loop failed") }) } } async fn handle<E: Debug + IntoFoo + 'static>( callback_fn: Box<dyn Fn() -> Pin<Box<dyn Future<Output = Result<(), E>> + Send + Sync>> + Send + Sync>) -> Result<(), E> { perform(Box::new(move || (callback_fn)())).await } pub async fn perform< E: Debug + IntoFoo>( op: Box<dyn Fn() -> Pin<Box<dyn Future<Output = Result<(), E>> + Send + Sync>> + Send + Sync>, ) -> Result<(), E> { (op)().await } 这是一些真实代码的简化版本，我基本上必须在结构内部传递异步回调。该回调通过多个函数传递。其中之一在新生成的线程中调用该函数。当调用 handle 时，我得到的错误出现在线程生成代码中。错误是： error: lifetime may not live long enough --> src/indexer/callback.rs:41:41 | 27 | fn bootstrap(&self, input: StageReceiver) -> BootstrapResult { | - let's call the lifetime of this reference `'1` ... 41 | rt.block_on(handle_event(input, Box::new(move |ev: &Event| (self.f)(ev)), &retry_policy, utils)) | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cast requires that `'1` must outlive `'static` 我应该如何安排这个？愿意更改结构字段类型和任何类似的内容。但我必须注意：这个函数必须能够被多次调用（它可能位于handle中的循环内）。其他一些线程建议在 Box 中传递异步回调，其结果是固定的装箱特征对象。这就是我尝试这个系统的原因。您不能在新线程中使用非 'static &self 引用。一种选择是使用 Arc 而不是 Box，然后克隆它： use std::{fmt::Debug, future::Future, pin::Pin, sync::Arc, thread::JoinHandle}; use tokio::runtime::Runtime; struct Callback<E> { f: Arc<dyn Fn() -> Pin<Box<dyn Future<Output = Result<(), E>> + Send + Sync>> + Send + Sync>, } trait Provider { fn setup(&self) -> JoinHandle<()>; } enum Foo { A, B, } trait IntoFoo { fn into_foo(&self) -> Foo; } impl<E: Debug + IntoFoo + 'static> Provider for Callback<E> { fn setup(&self) -> JoinHandle<()> { let f = Arc::clone(&self.f); std::thread::spawn(move || { // Running async function sycnhronously within another thread. let rt = Runtime::new().unwrap(); rt.block_on(handle(f)).expect("request loop failed") }) } } async fn handle<E: Debug + IntoFoo + 'static>( callback_fn: Arc< dyn Fn() -> Pin<Box<dyn Future<Output = Result<(), E>> + Send + Sync>> + Send + Sync, >, ) -> Result<(), E> { perform(callback_fn).await } pub async fn perform<E: Debug + IntoFoo>( op: Arc<dyn Fn() -> Pin<Box<dyn Future<Output = Result<(), E>> + Send + Sync>> + Send + Sync>, ) -> Result<(), E> { op().await } 您可以在较少的地方使用 Arc，并通过将回调包装在其自己的函数中并将其框起来，使用 Box 代替（如果您有需要使用的现有 API）。

asynchronous rust callback lifetime rust-tokio

回答 1 投票 0

我可以从 socket2::Socket 转换为 Tokio::net::TcpStream 吗？

我想使用 tokio::net::TcpStream 作为异步 TCP 监听器。另一方面，我也想在socket2::Socket中使用set_reuse_address、set_reuse_port和set_nonblocking。我怎样才能

sockets asynchronous rust rust-tokio tcplistener

回答 1 投票 0

同步使用HttpClient的“正确方法”是什么？

我在“正确的方式”周围使用了引号，因为我已经很清楚使用异步 API 的正确方法是简单地让异步行为在整个调用过程中传播...

c# asynchronous async-await

回答 5 投票 0

withUnsafeThrowingContinuation 表达式类型在没有更多上下文的情况下不明确

我尝试使用 make @escaping 函数与 withUnsafeThrowingContinuation 进行异步/等待，但出现错误：没有更多上下文，表达类型不明确代码：私有函数 asyncUplo...