显示此包…
2 个稳定版本
2.0.1 | 2021年4月3日 |
---|---|
2.0.0 | 2021年4月2日 |
#40 在 #tetcore
237 每月下载次数
在 54 个 包中使用(直接使用2个)
385KB
7K SLoC
运行时异步,纯计算任务。
许可证:Apache-2.0
lib.rs
:
运行时任务。
包含用于生成并行纯计算任务的运行时可用函数。
注意:这是实验性API。注意:在实际运行时,请确保您不会产生无界的并行性。所以这不是使用它的好例子
fn my_parallel_computator(data: Vec<u8>) -> Vec<u8> {
unimplemented!()
}
fn test(dynamic_variable: i32) {
for _ in 0..dynamic_variable { tp_tasks::spawn(my_parallel_computator, vec![]); }
}
虽然这是一个好例子
use codec::Encode;
static STATIC_VARIABLE: i32 = 4;
fn my_parallel_computator(data: Vec<u8>) -> Vec<u8> {
unimplemented!()
}
fn test(computation_payload: Vec<u8>) {
let parallel_tasks = (0..STATIC_VARIABLE).map(|idx|
tp_tasks::spawn(my_parallel_computator, computation_payload.chunks(10).nth(idx as _).encode())
);
}
当允许无界的并行性时,恶意交易可以利用它,并基于节点拥有的资源量对网络共识进行分区。
依赖项
~3–11MB
~123K SLoC