feat(dispatcher): dispatch blocking fn's

compio-rs / compio

A thread-per-core Rust runtime with IOCP/io_uring/polling.

MIT License

420 stars 37 forks source link

Closed George-Miao closed 4 months ago

George-Miao commented 4 months ago

This PR adds dispatch_blocking to dispatcher that utilizes the asyncify pool.

In this PR:

Asyncify pool now accepts dispatchables other than FnOnce
Added dispatch_blocking that returns Result<oneshot::Receiver<R>> to obtain the result from the spawned task

George-Miao commented 4 months ago

The blocking closure should run in the Asyncify thread pool, not in the async work thread.

I don't quite understand, it is already

Berrysoft commented 4 months ago

Oh, my fault.