码迷,mamicode.com
首页 > 其他好文 > 详细

SDL SDL_CondWait及SDL_CondSignal使用

时间:2018-01-22 15:16:46      阅读:212      评论:0      收藏:0      [点我收藏+]

标签:thread   dbr   唤醒   typedef   就是   list   分配   ext   cas   

头文件
#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;
        }
        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

SDL SDL_CondWait及SDL_CondSignal使用

标签:thread   dbr   唤醒   typedef   就是   list   分配   ext   cas   

原文地址:http://blog.51cto.com/fengyuzaitu/2063664

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!