4

2 つの異なるスレッドで 2 つの異なるカメラから画像をキャプチャできるプログラムを作成しようとしています。同じスレッドでこれを行うと、cvQueryFrame を 2 倍の時間待機し続ける必要があるため、30 fps で画像を取得できません (各カメラから 15 FPS を取得します)。

このSOの投稿を見てみましたが、これは1台のカメラでしか機能しません。cvQueryFrame と boost::thread を一緒に使用する

私の現在のプログラムではさまざまな結果が得られます。メモリリークが発生することもあります。通常は何も起こっていないだけで、数秒間ワーリングすることもありますが、画像は再びフリーズします。奇妙なことに、以前に cvShowImage を呼び出さずに、imageProcessing 関数に何か便利なことをさせたときに、両方のカメラからリアルタイムの結果を得ていることがわかりました。これは、この作業を行うことは可能ですが、どこかで愚かな間違いを犯したことを意味すると思います。私のOSはLINUXで、OpenCV 2.4を使用しています

私のコード:

#include <iostream>
#include <cstdio>
#include <cv.h>
#include <ml.h>
#include <cvaux.h>
#include <highgui.h>
#include <vector>
#include <stdio.h>
#include "producer_consumer_queue.hpp"



//Camera settings
int cameraWidth = 1280;
int cameraHeight = 720;
int waitKeyValue = 5;
bool threads_should_exit = false;

CvCapture * capture;
CvCapture * capture2;

using namespace std;
using namespace cv;

void grabFrame(concurrent_queue<IplImage* > * frame_queue, int camNumber) {
    try {
        //Load first frames
        cout << "grabFrame: " << camNumber << " init with " << cameraWidth << " x " << cameraHeight << endl;

        IplImage* frame;
        if (camNumber == 0)frame = cvQueryFrame(capture);
        if (camNumber == 1)frame = cvQueryFrame(capture2);
        while (frame && !threads_should_exit) {
            if (camNumber == 0)frame = cvQueryFrame(capture);
            if (camNumber == 1)frame = cvQueryFrame(capture2);
            IplImage* frame_copy = NULL;
            frame_copy = cvCloneImage(frame);

            if (camNumber == 0)cvShowImage("NE", frame);
            cout << "grabFrame: " << camNumber << " pushing back to queue" << endl;
            frame_queue->push(frame_copy);

            int k = cvWaitKey(waitKeyValue);

            if (k == 1048603 || k == 27 || k == '\r') {

                cout << "grabFrame: Process killed" << endl;
                //release memory
                threads_should_exit = true;
            }

        }
    } catch (const concurrent_queue<IplImage* >::Canceled & e) {
        cout << "grabFrame: Show thread is canceled" << endl;
        return;
    }

}

void processFrames(concurrent_queue<IplImage* > * frame_queue0, concurrent_queue<IplImage* > * frame_queue1) {
    try {
        do {
            cout << "processFrames: Processing two frames" << endl;
            IplImage* frm = NULL;
            frame_queue0->wait_and_pop(frm);
            IplImage * frm2 = NULL;
            frame_queue1->wait_and_pop(frm2);
            cvReleaseImage(&frm);
            cvReleaseImage(&frm2);
        } while (!threads_should_exit);
    } catch (const concurrent_queue<IplImage* >::Canceled & e) {
        cout << "processFrames: Processing thread is canceled" << endl;
        return;
    }
}

int main() {
    capture = cvCreateCameraCapture(0);
    capture2 = cvCreateCameraCapture(1);
    cvSetCaptureProperty(capture, CV_CAP_PROP_FRAME_WIDTH, cameraWidth);
    cvSetCaptureProperty(capture, CV_CAP_PROP_FRAME_HEIGHT, cameraHeight);
    cvSetCaptureProperty(capture2, CV_CAP_PROP_FRAME_WIDTH, cameraWidth);
    cvSetCaptureProperty(capture2, CV_CAP_PROP_FRAME_HEIGHT, cameraHeight);

    boost::thread_group frame_workers;
    boost::thread_group frame_workers2;
    concurrent_queue<IplImage* > frame_queue(&frame_workers);
    concurrent_queue<IplImage* > frame_queue2(&frame_workers2);

    boost::thread * query_thread = new boost::thread(processFrames, &frame_queue, &frame_queue2);
    boost::thread * cam0_thread = new boost::thread(grabFrame, &frame_queue, 0);
    usleep(10000);
    boost::thread * cam1_thread = new boost::thread(grabFrame, &frame_queue2, 1);

    frame_workers.add_thread(query_thread);
    frame_workers.add_thread(cam0_thread);

    frame_workers2.add_thread(query_thread);
    frame_workers2.add_thread(cam1_thread);
    while (true) {
        if (threads_should_exit) {
            cout << "Main: threads should be killed" << endl;
            while (!frame_queue.empty()) {
                usleep(10000);
            }
            frame_workers.remove_thread(query_thread);
            frame_workers2.remove_thread(query_thread);
            frame_workers.remove_thread(cam0_thread);
            frame_workers2.remove_thread(cam1_thread);

            frame_workers.join_all();
            break;
        }
        usleep(10000);
    }

    return 0;

}

編集：

を呼び出さないときにすべてが正常に機能しているかどうかを確認するために、一枚の紙を検出する簡単な関数を追加しましたcvShowImage()。を呼び出さなくても、私のプログラムは一枚の紙をうまく検出できますcvShowImage()。私が行うと、プログラムは再び奇妙な動作をしてフリーズします。

4

1 に答える 1

1

GUI を操作するスレッドは 1 つだけにする必要があります (これは、ほぼすべての GUI フレームワークに当てはまります)。cvShowImageメインの「GUI スレッド」からのみ呼び出されるように、コードを編成する必要があります。

で行われている作業はquery_thread、メイン スレッド内でも同じように簡単に実行できるようです。

于 2012-07-09T14:42:47.363 に答える