13518219792
头文件
#include "SDL.h"
#include "SDL_thread.h"
int SDL_CondWait(SDL_cond *cond, SDL_mutex *mut);//等待条件变量
SDL_CondWait：释放传递进来的锁，然后当条件变量满足的时候，等待其他的线程调用SDL_CondSignal或者SDL_CondBroadcast
改变条件变量cond,然后重新获取锁，然后返回。在调用该函数之前必须先调用SDL_LockMutex获取
锁。当信号被触发的时候就返回0，错误的时候返回-1
简而言之，就是释放锁，让其他的线程有机会获取到锁，满足条件的时候，其他的线程会调用SDL_CondSignal或者SDL_CondBroadcast
释放锁，并且让当前的线程继续执行下去
int SDL_CondSignal(SDL_cond *cond);//唤醒正在等待条件变量发生改变的线程
代码
typedef struct PacketQueue {
AVPacketList *first_pkt, *last_pkt;
int nb_packets; //为包的总数
int size; //为所有包的大小
SDL_mutex *mutex; //互斥锁
SDL_cond *cond; //条件变量
} PacketQueue;
我们自己创建的用于构建Packet队列的数据结构
AVPacketList
A simple linked list for packets.
AVPacket pkt
AVPacketList * next
void packet_queue_init(PacketQueue *q)
{
memset(q,0,sizeof(PacketQueue));
q->mutex = SDL_CreateMutex();
q->cond=SDL_CreateCond();
}
对PacketQueue数据结构进行初始化
用于给PacketQueue数据结构中填入包的函数
int packet_queue_put(PacketQueue *q,AVPacket *pkt)
{
AVPacketList *pkt1;
if(av_dup_packet(pkt)<0)
{
return -1; //检查是否为NULL，为NULL则自己填充，否则返回-1
}
pkt1 = av_malloc(sizeof(AVPacketList));//给AVPacketList分配空间
if (!pkt1)
return -1;
pkt1->pkt = *pkt;
pkt1->next = NULL;
SDL_LockMutex(q->mutex); //对PacketQueue进行操作，先锁定互斥变量
if (!q->last_pkt)
q->first_pkt = pkt1;
else
q->last_pkt->next = pkt1;
q->last_pkt = pkt1;
q->nb_packets++;
q->size += pkt1->pkt.size;
SDL_CondSignal(q->cond); //发送条件信号，方便等待数据的地方唤醒
SDL_UnlockMutex(q->mutex); //解锁
return 0;
}
接收数据
static int packet_queue_get(PacketQueue *q, AVPacket *pkt, int block)
{
AVPacketList *pkt1;
int ret;
SDL_LockMutex(q->mutex);//锁定mutex
for(;;)
{
if(quit)
{
ret =-1;
break;
}
pkt1=q->first_pkt;
if (pkt1) {
q->first_pkt = pkt1->next;
if (!q->first_pkt)
q->last_pkt = NULL;
q->nb_packets--;
q->size -= pkt1->pkt.size;
*pkt = pkt1->pkt;
av_free(pkt1);
ret = 1;
break;
}
//如果block设置为false,说明不阻塞等待数据包，直接返回
else if (!block) {
ret = 0;
break;
}
else {
//等待数据包进入队列，然后才返回
SDL_CondWait(q->cond, q->mutex);
}
}
SDL_UnlockMutex(q->mutex);
return ret;
}
SDL_CondWait先检测是否满足条件，若不满足，解锁mutex，wait，
直至被SDL_CondSignal()函数或者SDL_CondBroadcast()函数通知，
则锁定mutex并返回
参考
http://blog.sina.com.cn/s/blog_4ae178ba01010fns.html
另外有需要云服务器可以了解下创新互联scvps.cn，海内外云服务器15元起步，三天无理由+7*72小时售后在线，公司持有idc许可证，提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案，具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势，专为企业上云打造定制，能够满足用户丰富、多元化的应用场景需求。
