class FileMD5Thread {
private:
    char* listFile;
    char* outMD5File;
    unsigned short int threadCount = 24;//线程数 
    static std::mutex logLock;//日志锁
    std::mutex* plck;//默认所有对象使用相同的锁
    
    ......
}

int FileMD5Thread::fileMd5Sum(sql::Statement* state, ThreadsAction action)
{
    constexpr int FILE_NAME_PATH_SIZE = 512;
    //char* buff = new char[FILE_NAME_PATH_SIZE*2];
    char buff[FILE_NAME_PATH_SIZE * 2] = { 0 };
    char buffMD5[128] = { 0 };
    char fileName[FILE_NAME_PATH_SIZE] = { 0 };
    char filePath[FILE_NAME_PATH_SIZE] = { 0 };
    while (inFile.getline(buff, FILE_NAME_PATH_SIZE))
    {
        try
        {// 捕捉getFileMD5抛出的错误
            strcpy(buffMD5, getFileMD5(buff).c_str());
        }
        catch (...)
        {
            this->endResetZero(buffMD5, 128);
            std::lock_guard<std::mutex> lockguard(logLock);
            errors++;
            outLog << "无法定位文件: " << buff << endl;
            cout << "无法定位文件: " << buff << endl;
        }
        cutStr(buff, filePath, fileName, '\\');
        switch (action)
        {
        case FileMD5Thread::ThreadsAction::TO_MYSQL:
        {   /*写入数据库*/
            sprintf(buff, "insert into mods_test(md5,filename,path) value(\"%s\",\"%s\",\"%s\")", buffMD5, fileName, filePath);
            gbkToUTF8(buff, FILE_NAME_PATH_SIZE);
            try
            {
                std::lock_guard<std::mutex> lockguard(*plck);
                state->executeUpdate(buff);
            }
            catch (...)
            {
                std::lock_guard<std::mutex> lockguard(logLock);
                errors++;
                outLog << buff << endl;
            }
        }
        break;
        case FileMD5Thread::ThreadsAction::TO_FILE:
        {   /*写入文件*/
            std::lock_guard<std::mutex> lockguard(*plck);
            //outFile << buff << endl << "[MD5]" << buffMD5 << endl;//写入文件
            outLog << fileName << " " << filePath << endl;
            outLog << buff << endl << endl;
        }
        break;
        default:
        {
            cout << "别乱搞!" << endl;
            return 404;
        }
        break;
        }//switch end
        this->endResetZero(buff, FILE_NAME_PATH_SIZE);
        this->endResetZero(fileName, FILE_NAME_PATH_SIZE);
        this->endResetZero(filePath, FILE_NAME_PATH_SIZE);
    }
    //delete[] buff;
    return errors;
}

/*==========以下是开启多线程的函数==========*/
int FileMD5Thread::run(sql::Connection* conn)
{
    /*传入Connection对象时,写入MySQL数据库
    */
    clock_t start_time = clock();//计时开始

    openIoFile();
    std::mutex lckSQL;//SQL写入锁
    this->plck = &lckSQL;
    sql::Statement* state = conn->createStatement();
    thread* pth = new thread[threadCount];
    if (pth == NULL) {
        return 404;
    }
    int i;
    for (i = 0; i < threadCount; i++) {
        pth[i] = thread(&FileMD5Thread::fileMd5Sum, this, state, ThreadsAction::TO_MYSQL);
    }
    for (i = 0; i < threadCount; i++) {
        pth[i].join();
    }
    //计时结束
    clock_t end_time = clock();
    outLog << "elapsed time:" << (double)clock() / CLK_TCK << "s\n"
        << "error count: " << errors;
    //收尾
    state->close();
    delete state;
    delete[] pth;
    closeIoFile();
    return errors;
}