在 C++ 中,使用 Windows API 实现多线程可以通过以下步骤完成:
#include <Windows.h>
#include <iostream>
#include <vector>
#include <thread>
void worker_function(int thread_id) {
std::cout << "Hello from thread " << thread_id << std::endl;
}
main
函数中创建多个线程:int main() {
const int num_threads = 5;
// 创建一个线程向量
std::vector<std::thread> threads;
// 启动新线程并添加到向量中
for (int i = 0; i < num_threads; ++i) {
threads.emplace_back(worker_function, i);
}
// 等待所有线程完成
for (auto& thread : threads) {
if (thread.joinable()) {
thread.join();
}
}
return 0;
}
这个示例展示了如何使用 C++11 的 std::thread
类来简化多线程操作。如果你只想使用 Windows API,可以参考以下代码:
#include <Windows.h>
#include <iostream>
#include <vector>
DWORD WINAPI worker_function(LPVOID lpParam) {
int thread_id = reinterpret_cast<int>(lpParam);
std::cout << "Hello from thread " << thread_id << std::endl;
return 0;
}
main
函数中创建多个线程:int main() {
const int num_threads = 5;
// 创建一个线程向量
std::vector<HANDLE> threads;
// 启动新线程并添加到向量中
for (int i = 0; i < num_threads; ++i) {
HANDLE hThread = CreateThread(
nullptr, // 默认安全属性
0, // 默认堆栈大小
worker_function, // 线程函数
reinterpret_cast<LPVOID>(i), // 传递给线程函数的参数
0, // 使用默认创建标志
nullptr // 不需要线程 ID
);
if (hThread == nullptr) {
std::cerr << "Error creating thread" << std::endl;
return 1;
}
threads.push_back(hThread);
}
// 等待所有线程完成
for (auto& hThread : threads) {
WaitForSingleObject(hThread, INFINITE);
CloseHandle(hThread);
}
return 0;
}
这个示例展示了如何使用 Windows API 的 CreateThread
函数来创建新线程。注意,这里我们使用 std::vector<HANDLE>
来存储线程句柄,以便稍后等待它们完成并关闭它们。