上面的get函数看上去比较复杂,但是所有的同步函数基本上都是这样的设计的,看多了反而有一种八股文的感觉。刚开始看的同学可能觉得不是很习惯。不要紧,每天多看两眼,时间长了ok了。好了,接着我们继续去卡看信号量的释放函数是怎么处理的,大家做好心理准备哦!

static RAW_U16 internal_semaphore_put(RAW_SEMAPHORE *semaphore_ptr, RAW_U8 opt_wake_all)
{
 LIST *block_list_head;
 
 RAW_SR_ALLOC();

 #if (RAW_SEMA_FUNCTION_CHECK > 0)
 
 if (semaphore_ptr == 0) {
  
  return RAW_NULL_OBJECT;
 }
 
 #endif

 block_list_head = &semaphore_ptr->common_block_obj.block_list;
 
 RAW_CRITICAL_ENTER();
 /*if no block task on this list just return*/
 if (is_list_empty(block_list_head)) {       
    
  if (semaphore_ptr->count == 0xffffffff) {

   RAW_CRITICAL_EXIT();
   return RAW_SEMOPHORE_OVERFLOW;

  }
  /*increase resource*/
     semaphore_ptr->count++;                                     
    
     RAW_CRITICAL_EXIT();
     return RAW_SUCCESS;
 }

 /*wake all the task blocked on this semphore*/
 if (opt_wake_all) {

  while (!is_list_empty(block_list_head)) {
   raw_wake_object(list_entry(block_list_head->next, RAW_TASK_OBJ, task_list));
  }

 }

 else {
  
  /*Wake up the highest priority task block on the semaphore*/
  raw_wake_object(list_entry(block_list_head->next, RAW_TASK_OBJ, task_list));
 }
 
 RAW_CRITICAL_EXIT();

 raw_sched();   

 return RAW_SUCCESS;
}

  看上去,信号量的释放函数也比较长,不管只要有耐心,都是可以看明白的,我们来具体分析一下,

  (1)判断参数的合法性;

  (2)判断当前是否有等待队列,如果没有,则count自增,函数返回,当然如果count达到了0xffffffff也要返回,不过概率极低;

  (3) 当前存在等待队列,根据opt_wake_all的要求是唤醒一个线程还是唤醒所有的线程;

  (4)调用系统调度函数,让高优先级任务及时得到运行的机会;

  (5)当前线程再次得到运行的机会,函数返回。