Итак, у меня есть расширенный класс очереди, который поддерживает многопоточность, описанную здесь.
В моих объявлениях классов у меня есть
//...
struct VideoSample
{
const unsigned char * buffer;
int len;
};
ConcurrentQueue<VideoSample * > VideoSamples;
//...
struct AudioSample
{
const unsigned char * buffer;
int len;
};
ConcurrentQueue<AudioSample * > AudioSamples;
//...
В моем классе у меня есть функция:
void VideoEncoder::AddFrameToQueue(const unsigned char *buf, int size )
{
VideoSample * newVideoSample = new VideoSample;
VideoSamples.try_pop(newVideoSample);
newVideoSample->buffer = buf;
newVideoSample->len = size;
VideoSamples.push(newVideoSample);
//free(newVideoSample->buffer);
//delete newVideoSample;
}
для моего приложения требуется сохранение только одного кадра в очереди.
предоставленный здесь ответ о том, как удалить структуру, бесполезен в этом случае, потому что приложение давит.
У меня есть аналогичный код для аудио очереди.
void VideoEncoder::AddSampleToQueue(const unsigned char *buf, int size )
{
AudioSample * newAudioSample = new AudioSample;
newAudioSample->buffer = buf;
newAudioSample->len = size;
AudioSamples.push(newAudioSample);
url_write (url_context, (unsigned char *)newAudioSample->buffer, newAudioSample->len);
AudioSamples.wait_and_pop(newAudioSample);
//delete newAudioSample;
}
и функция, которая выполняется в отдельном потоке:
void VideoEncoder::UrlWriteData()
{
while(1){
switch (AudioSamples.empty()){
case true :
switch(VideoSamples.empty()){
case true : Sleep(5); break;
case false :
VideoSample * newVideoSample = new VideoSample;
VideoSamples.wait_and_pop(newVideoSample);
url_write (url_context, (unsigned char *)newVideoSample->buffer, newVideoSample->len);
break;
} break;
case false : Sleep(3); break;
}
}
}
Кстати: для потоковой передачи мультимедийных данных на URL-адрес я использую функцию ffmpeg.
Кстати: здесь код, который я использую для очередей:
#include <string>
#include <queue>
#include <iostream>
// Boost
#include <boost/thread.hpp>
#include <boost/timer.hpp>
template<typename Data>
class ConcurrentQueue
{
private:
std::queue<Data> the_queue;
mutable boost::mutex the_mutex;
boost::condition_variable the_condition_variable;
public:
void push(Data const& data)
{
boost::mutex::scoped_lock lock(the_mutex);
the_queue.push(data);
lock.unlock();
the_condition_variable.notify_one();
}
bool empty() const
{
boost::mutex::scoped_lock lock(the_mutex);
return the_queue.empty();
}
bool try_pop(Data& popped_value)
{
boost::mutex::scoped_lock lock(the_mutex);
if(the_queue.empty())
{
return false;
}
popped_value=the_queue.front();
the_queue.pop();
return true;
}
void wait_and_pop(Data& popped_value)
{
boost::mutex::scoped_lock lock(the_mutex);
while(the_queue.empty())
{
the_condition_variable.wait(lock);
}
popped_value=the_queue.front();
the_queue.pop();
}
Data& front()
{
boost::mutex::scoped_lock lock(the_mutex);
return the_queue.front();
}
};
У меня вопрос: Как почистить AddSampleToQueue и AddFrameToQueue, чтобы они не делали утечек памяти?
Кстати: я совершенно новичок во всех этих общих/автоматических вещах С++. Так сказать новичок. Поэтому, пожалуйста, предоставьте примеры кода, которые работают, по крайней мере, интегрированы в мой код, потому что я предоставил весь свой код. Так что если вы знаете, что делать - пожалуйста, попробуйте интегрировать свои знания в мой пример. Спасибо. И если вы можете показать мне, как это сделать без использования общих / автоматических указателей, я был бы очень рад.
swhich(somebool) {case true:... case false:...}УРА! :)) - person Armen Tsirunyan schedule 13.11.2010