// 工作線程
void* pthreadFunc(void* arg) {
    int sleepMs = 0;
    // 0: 從自定義線程參數(shù)中獲取token, 配置文件等參數(shù).
    ParamStruct* tst = (ParamStruct*)arg;
    if (tst == NULL) {
        cout << "arg is not valid." << endl;
        return NULL;
    }
    // 打開音頻文件, 獲取數(shù)據(jù)
    FILE* file = fopen(tst->fileName.c_str(), "rb");
    if (NULL == file) {
        cout << tst->fileName << " isn't exist." << endl;
        return NULL;
    }
    fseek(file, 0, SEEK_END);
    int fileSize = ftell(file);  // 獲取音頻文件的長度
    fseek(file, 0, SEEK_SET);
    /*
    * 創(chuàng)建實(shí)時(shí)音頻流同步識(shí)別SpeechTranscriberSyncRequest對(duì)象.
    * request對(duì)象在一個(gè)會(huì)話周期內(nèi)可以重復(fù)使用.
    * 會(huì)話周期是一個(gè)邏輯概念. 比如Demo中, 指讀取, 發(fā)送完整個(gè)音頻文件數(shù)據(jù)的時(shí)間.
    * 音頻文件數(shù)據(jù)發(fā)送結(jié)束時(shí), 可以releaseTranscriberSyncRequest()釋放對(duì)象.
    * createTranscriberSyncRequest(), sendSyncAudio(), getTranscriberResult(), releaseTranscriberSyncRequest()請(qǐng)?jiān)?/code>
    * 同一線程內(nèi)完成, 跨線程使用可能會(huì)引起異常錯(cuò)誤.
    */
    /*
     * 1: 創(chuàng)建實(shí)時(shí)音頻流識(shí)別SpeechTranscriberSyncRequest對(duì)象
     */
    SpeechTranscriberSyncRequest* request = NlsClient::getInstance()->createTranscriberSyncRequest();
    if (request == NULL) {
        cout << "createTranscriberSyncRequest failed." << endl;
        return NULL;
    }
    request->setAppKey(tst->appkey.c_str()); // 設(shè)置AppKey, 必填參數(shù), 請(qǐng)參照官網(wǎng)申請(qǐng)
    request->setFormat("pcm"); // 設(shè)置音頻數(shù)據(jù)編碼格式, 可選參數(shù)，目前支持pcm, opu. 默認(rèn)是pcm
    request->setSampleRate(16000); // 設(shè)置音頻數(shù)據(jù)采樣率, 可選參數(shù)，目前支持16000, 8000. 默認(rèn)是16000
    request->setIntermediateResult(true); // 設(shè)置是否返回中間識(shí)別結(jié)果, 可選參數(shù). 默認(rèn)false
    request->setPunctuationPrediction(true); // 設(shè)置是否在后處理中添加標(biāo)點(diǎn), 可選參數(shù). 默認(rèn)false
    request->setInverseTextNormalization(true); // 設(shè)置是否在后處理中執(zhí)行數(shù)字轉(zhuǎn)寫, 可選參數(shù). 默認(rèn)false
    request->setSemanticSentenceDetection(false); // 設(shè)置是否語義斷句, 可選參數(shù). 默認(rèn)false
    request->setMaxSentenceSilence(500); // 設(shè)置vad閥值, 可選參數(shù). 合法參數(shù)范圍200～2000(ms), 默認(rèn)值800ms
    request->setToken(tst->token.c_str()); // 設(shè)置賬號(hào)校驗(yàn)token, 必填參數(shù)
    int sentSize = 0;   // 已發(fā)送的文件數(shù)據(jù)大小
    while (sentSize < fileSize) {
        char data[FRAME_SIZE] = {0};
        int size = fread(data, sizeof(char), sizeof(char) * FRAME_SIZE, file);
        AudioDataStatus status;
        if (sentSize == 0) {
            status = AUDIO_FIRST;   // 發(fā)送第一塊音頻數(shù)據(jù)
        }
        else if (sentSize + size < fileSize) {
            status = AUDIO_MIDDLE;  // 發(fā)送中間音頻數(shù)據(jù)
        }
        else if (sentSize + size == fileSize) {
            status = AUDIO_LAST;    // 發(fā)送最后一塊音頻數(shù)據(jù)
        }
        sentSize += size;
        /*
        * 2: 發(fā)送音頻數(shù)據(jù). sendAudio返回-1表示發(fā)送失敗, 可在getTranscriberResult函數(shù)中獲得失敗的具體信息
        * 對(duì)于第四個(gè)參數(shù), request對(duì)象format參數(shù)為pcm時(shí), 使用false即可. format為opu, 使用壓縮數(shù)據(jù)時(shí), 需設(shè)置為true.
        */
        request->sendSyncAudio(data, size, status);
        /*
        *語音數(shù)據(jù)發(fā)送控制：
        *語音數(shù)據(jù)是實(shí)時(shí)的, 不用sleep控制速率, 直接發(fā)送即可.
        *語音數(shù)據(jù)來自文件, 發(fā)送時(shí)需要控制速率, 使單位時(shí)間內(nèi)發(fā)送的數(shù)據(jù)大小接近單位時(shí)間原始語音數(shù)據(jù)存儲(chǔ)的大小.
        */
        sleepMs = getSendAudioSleepTime(6400, 16000, 1); // 根據(jù) 發(fā)送數(shù)據(jù)大小，采樣率，數(shù)據(jù)壓縮比 來獲取sleep時(shí)間
        /*
        * 3: 語音數(shù)據(jù)發(fā)送延時(shí)控制
        */
#ifdef _WIN32
        Sleep(sleepMs);
#else
        usleep(sleepMs * 1000);
#endif
        /*
        * 4: 獲取識(shí)別結(jié)果
        * 接收到EventType為TaskFailed, closed, completed事件類型時(shí)，停止發(fā)送數(shù)據(jù)
        * 部分錯(cuò)誤可收到多次TaskFailed事件，只要發(fā)生TaskFailed事件，請(qǐng)停止發(fā)送數(shù)據(jù)
        */
        bool isFinished = false;
        std::queue<NlsEvent> eventQueue;
        request->getTranscriberResult(&eventQueue);
        while (!eventQueue.empty()) {
            NlsEvent _event = eventQueue.front();
            eventQueue.pop();
            NlsEvent::EventType type = _event.getMsgType();
            switch (type)
            {
            case NlsEvent::TranscriptionStarted:
                cout << "************* Transcriber started *************" << endl;
                break;
            case NlsEvent::SentenceBegin:
                cout << "************* Detected sentence begin *************" << endl;
                cout << "sentence index: " << _event.getSentenceIndex() << endl;
                cout << "sentence time: " << _event.getSentenceTime() << endl;
                break;
            case NlsEvent::TranscriptionResultChanged:
                cout << "************* Transcriber has sentence middle result *************" << endl;
                cout << "sentence index: " << _event.getSentenceIndex() << endl;
                cout << "sentence time: " << _event.getSentenceTime() << endl;
                cout << "result: " << _event.getResult() << endl;
                break;
            case NlsEvent::SentenceEnd:
                cout << "************* Detected sentence end *************" << endl;
                cout << "sentence index: " << _event.getSentenceIndex() << endl;
                cout << "sentence time: " << _event.getSentenceTime() << endl;
                cout << "result: " << _event.getResult() << endl;
                break;
            case NlsEvent::TranscriptionCompleted:
                cout << "************* Transcriber completed *************" << endl;
                isFinished = true;
                break;
            case NlsEvent::TaskFailed:
                cout << "************* TaskFailed *************" << endl;
                isFinished = true;
                break;
            case NlsEvent::Close:
                cout << "************* Closed *************" << endl;
                isFinished = true;
                break;
            default:
                break;
            }
            cout << "allMessage: " << _event.getAllResponse() << endl;
        }
        if (isFinished) {
            break;
        }
    }
    // 關(guān)閉音頻文件
    fclose(file);
    /*
    * 5: 識(shí)別結(jié)束, 釋放request對(duì)象
    */
    NlsClient::getInstance()->releaseTranscriberSyncRequest(request);
    return NULL;
}