优化SMP创建并行线程失败时的处理逻辑

2023-06-25 17:57:24 +08:00
parent f3e0cb3df2
commit 0aa4df4c6d
1 changed files with 1 additions and 1 deletions
--- a/src/gausskernel/process/stream/streamCore.cpp
+++ b/src/gausskernel/process/stream/streamCore.cpp
@ -744,7 +744,7 @@ const List* StreamNodeGroup::getStreamPairList()
 void StreamNodeGroup::initStreamThread(StreamProducer* producer, uint8 smpIdentifier, StreamPair* pair)
 {
    ThreadId producerThreadId = ApplyStreamThread(producer);
-    if (producerThreadId != 0) {
+    if (producerThreadId != 0 && producerThreadId != InvalidTid) {
 #ifdef __aarch64__
        pg_memory_barrier();
 #endif