forked from huawei/mindspore2022
!32543 [Bugfix][PyNative] Coredump
Merge pull request !32543 from caifubi/master-pynative-async-coredump
This commit is contained in:
commit
050a0e7052
|
|
@ -112,7 +112,8 @@ bool OpExecutor::BuildQueueFull() {
|
|||
return op_build_tasks_.size() > kMaxQueueSize;
|
||||
}
|
||||
|
||||
bool OpExecutor::ActorInQueue(const std::string &actor_info) const {
|
||||
bool OpExecutor::ActorInQueue(const std::string &actor_info) {
|
||||
std::lock_guard<std::mutex> lock(task_mutex_);
|
||||
auto iter = actor_in_queue_.find(actor_info);
|
||||
return iter != actor_in_queue_.end();
|
||||
}
|
||||
|
|
|
|||
|
|
@ -66,7 +66,7 @@ class BACKEND_EXPORT OpExecutor {
|
|||
|
||||
// Determine if there is another task with the same name in execution.
|
||||
// Tasks with the same name use the same CNode cache. So we need to wait.
|
||||
bool ActorInQueue(const std::string &actor_info) const;
|
||||
bool ActorInQueue(const std::string &actor_info);
|
||||
|
||||
// Wait for all OpRunTasks to finish executing.
|
||||
void Wait();
|
||||
|
|
|
|||
Loading…
Reference in New Issue