2

私はリアルタイムの音楽アプリケーションに取り組んでいます。初心者としてブーストライブラリを操作する。保護されたSyncronizedQueueを使用してプロデューサー/コンシューマーの関係を実装しました。実際には、https： //www.quantnet.com/cplusplus-multithreading-boost/の18.11セクションと18.12セクションを実装しました。MIDI入力を解析すると、次の例外が発生します。

terminate called after throwing an instance of 'boost::exception_detail::clone_impl
<boost::exception_detail::error_info_injector<boost::lock_error> >'
what():  boost::lock_error

プロデューサーで入力を解析するためのコード：

RtMidiIn *midiin = new RtMidiIn();
std::vector<unsigned char> message;
int nBytes, i;
double stamp;
m_queue=queue;        

// Check available ports.
unsigned int nPorts = midiin->getPortCount();
if ( nPorts == 0 ) {
    std::cout << "No ports available!\n";
    goto cleanup;
}

midiin->openPort( 1 );

// Don't ignore sysex, timing, or active sensing messages.
midiin->ignoreTypes( false, false, false );

// Install an interrupt handler function.
done = false;
(void) signal(SIGINT, finish);

// Periodically check input queue.
std::cout << "Reading MIDI from port ... quit with Ctrl-C.\n";
while ( !done ) {
  stamp = midiin->getMessage( &message );
  nBytes = message.size();
  if(nBytes>0){
    if((message.size()!=1)&&((int)message.at(0)!=137)){
            for ( i=0; i<nBytes; i++ )
            std::cout << "Byte " << i << " = " << (int)message[i] << ", ";
            if ( nBytes > 0 )
            std::cout << "stamp = " << stamp << std::endl;
            m_queue->Enqueue("asd");
    }
}
}

初めて遭遇したときに壊れます：

m_queue->Enqueue("asd");

実行しようとすると：

boost::unique_lock<boost::mutex> lock(m_mutex);

助けていただければ幸いです。

編集1：

これはSynchronizedQueueオブジェクトです。Enqueue（）を呼び出すと、例外がスローされます。

template <typename T>
class SynchronizedQueue
{
private:
    std::queue<T> m_queue;                      // Use STL queue to store data
    mutable boost::mutex m_mutex;                       // The mutex to synchronise on
    boost::condition_variable m_cond;       // The condition to wait for

public:

    // Add data to the queue and notify others
    void Enqueue(const T& data)
    {
        // Acquire lock on the queue
            boost::unique_lock<boost::mutex> lock(m_mutex);
        // Add the data to the queue
        m_queue.push(data);
            // Notify others that data is ready
        m_cond.notify_one();
        } // Lock is automatically released here

    // Get data from the queue. Wait for data if not available
    T Dequeue()
    {

        // Acquire lock on the queue
        boost::unique_lock<boost::mutex> lock(m_mutex);
        //lock();
        // When there is no data, wait till someone fills it.
        // Lock is automatically released in the wait and obtained 
        // again after the wait
        while (m_queue.size()==0) m_cond.wait(lock);

        // Retrieve the data from the queue
        T result=m_queue.front(); m_queue.pop();
        return result;
    } // Lock is automatically released here
};
4

1 に答える 1

4

ほとんどの場合、私がそのような問題に遭遇したとき、ロックされたミューテックスはすでに破壊されているか、まだ構築されていません。パーサースレッドが解析を開始したときに、パーサーに渡すキューは既に作成されていますか？または、ローカル変数としてキューを含むループの終了が停止した可能性がありますか？簡単なテストを実行して、キューにd'torを追加し、そこにブレークポイントを設定できるかもしれません。

Torstenに関して

于 2012-06-06T20:01:46.833 に答える