diff --git a/LFtid1056/main_thread.cpp b/LFtid1056/main_thread.cpp index 8112c3c..1a4a966 100644 --- a/LFtid1056/main_thread.cpp +++ b/LFtid1056/main_thread.cpp @@ -292,6 +292,16 @@ int main() { free(index); } } + else if (i == 2){ + //接口和mq + char* argv[] = { (char*)index,(char*)"-dcfg_stat_data", (char*)"-s1_1" }; + ThreadArgs* args = new ThreadArgs{3, argv}; + if (pthread_create(&thread_info[i].tid, NULL, cloudfrontthread, args) != 0) { + printf("Failed to create message processor thread %d\n", i); + delete args; // 如果线程没创建成功就手动释放 + free(index); + } + } else { // 其他工作线程 // 这里简化为空,实际应用中可添加其他线程