api
blocking.ch
Declarations in blocking.ch
1 declarationsasync
Declarations
Public only
async#
Publicnamespace
namespace async
function would copy its heap-allocated capture and double-free it.
BlockingState#
Publicstruct
struct BlockingState<T> {
var m : mutex
var ready : bool
var consumed : bool
var abandoned : bool
var value : Option<T>
var task : function<func() : T>
var vtbl : *FutureTable<T>
}
delete#
function
func delete(self : *BlockingState) : void
blocking_drop#
Publicfunction
func blocking_drop<T>(frame : *void) : void
blocking_pool#
Publicfunction
func blocking_pool() : *ThreadPool
spawn_blocking#
Publicfunction
Run `f` on the blocking pool and return its future. Await it with