要在C++中实现多线程压缩可以使用Minizip库结合C++的多线程库(如std::thread)来实现。以下是一个简单的示例代码:
#include <iostream>
#include <thread>
#include "minizip/zip.h"
void compressFile(const std::string& filePath) {
std::string zipFilePath = filePath + ".zip";
zipFile zf = zipOpen(zipFilePath.c_str(), APPEND_STATUS_CREATE);
if (zf == NULL) {
std::cerr << "Error opening zip file " << zipFilePath << std::endl;
return;
}
zip_fileinfo fileinfo;
memset(&fileinfo, 0, sizeof(zip_fileinfo));
zipOpenNewFileInZip(zf, filePath.c_str(), &fileinfo, NULL, 0, NULL, 0, NULL, Z_DEFLATED, Z_DEFAULT_COMPRESSION);
FILE* file = fopen(filePath.c_str(), "rb");
char buffer[1024];
int bytesRead;
while ((bytesRead = fread(buffer, 1, sizeof(buffer), file)) > 0) {
zipWriteInFileInZip(zf, buffer, bytesRead);
}
zipCloseFileInZip(zf);
zipClose(zf);
fclose(file);
std::cout << "File compressed: " << filePath << std::endl;
}
int main() {
std::vector<std::string> files = {"file1.txt", "file2.txt", "file3.txt"};
std::vector<std::thread> threads;
for (const std::string& file : files) {
threads.push_back(std::thread(compressFile, file));
}
for (std::thread& t : threads) {
t.join();
}
return 0;
}
在上面的代码中,我们首先定义了一个compressFile
函数,该函数用于压缩一个文件。然后在main
函数中,我们创建了一个文件列表files
,并为每个文件创建一个新的线程来执行compressFile
函数。最后,我们等待所有线程执行完毕。
需要注意的是,在使用Minizip库时要包含正确的头文件并链接对应的库文件。在上面的例子中,我们使用了Minizip的zip.h头文件。您需要根据您的环境和工具链做相应的调整。