zhangyiss/mlx
1
0
Fork 0
mirror of https://github.com/ml-explore/mlx.git synced 2025-06-29 21:11:16 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Make eval just wait if all arrays are scheduled (#1368)

Browse Source
This commit is contained in:
Angelos Katharopoulos 2024-08-27 17:01:22 -07:00 committed by GitHub
parent cdb59faea6
commit e64349bbdd
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 25 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
mlx/transforms.cpp
View File

@ -186,10 +186,35 @@ array eval_impl(std::vector<array> outputs, bool async) {
} }
void async_eval(std::vector<array> outputs) { void async_eval(std::vector<array> outputs) {
if (outputs.empty()) {
return;
}
if (std::none_of(outputs.begin(), outputs.end(), [](array& x) {
return x.status() == array::Status::unscheduled;
})) {
return;
}
eval_impl(std::move(outputs), true); eval_impl(std::move(outputs), true);
} }
void eval(std::vector<array> outputs) { void eval(std::vector<array> outputs) {
if (outputs.empty()) {
return;
}
if (std::none_of(outputs.begin(), outputs.end(), [](array& x) {
return x.status() == array::Status::unscheduled;
})) {
for (auto& x : outputs) {
if (!x.is_available()) {
x.event().wait();
}
}
return;
}
eval_impl(std::move(outputs), false).event().wait(); eval_impl(std::move(outputs), false).event().wait();
} }