types.h,thread.h

1,types.h

/**
  ******************************************************************************
  * @file      types.h
  * @author    sr
  * @version   V0.0.0.0
  * @date 2014.04.22
  * @brief     类型定义
  ******************************************************************************
  */

#ifndef __TYPES_H__
#define __TYPES_H__

#ifdef __cplusplus
extern "C" {
#endif

/* Define to prevent recursive inclusion
-------------------------------------*/
#include <stdio.h>     // 标准输入输出定义
#include <stdlib.h>     // 标准函数库定义
#include <stdbool.h>        // bool
#include <string.h>             // memset
#include <unistd.h>     // Unix标准函数定义，read,write...
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h> // 文件控制定义
#include <termios.h>     // POSIX中断控制定义
#include <errno.h>     // 错误号定义
#include <pthread.h>        // pthread_t,pthread_create...
#include <ctype.h>            // tolower


/* 类型定义 */
//typedef          char        int8_t;
typedef unsigned     char         uint8_t;

typedef signed        short         int16_t;
typedef unsigned     short         uint16_t;

typedef signed        int            int32_t;
typedef unsigned     int         uint32_t;

typedef signed        long long     int64_t;
typedef unsigned long long         uint64_t;




/* 0，全局 */
#define    BUFFER_SIZE                256
#define    MAXARGS                    36        /* max number of command args    */

/* 1，COM，串口相关*/
#define    COM_TYPE_UPPER_DEVICE    1
#define    COM_TYPE_LOWER_DEVICE    2

#define    COM_BUFFER_SIZE            (BUFFER_SIZE)

#define    CFG_PROMPT                "[SANRAY]# "    /* Monitor Command Prompt    */


/* 2，pools，池相关 */



/* 3，命令相关*/
#define    CMD_DATA_LEN_MAX        (BUFFER_SIZE)


/* 4，环形缓冲区相关 */
    /* 环形缓冲区中保存的元素的最大个数 */
#define    CBUF_MAX                32






#ifdef __cplusplus
}
#endif

#endif
/* END OF FILE
---------------------------------------------------------------*/

2,thread.h

/**
  ******************************************************************************
  * @file      thread.h
  * @author    sr
  * @version   V0.0.0.0
  * @date      2014.05.16
  * @brief     多线程中相关封装
  * @Bibliography    nginx
  ******************************************************************************
  */

#ifndef __THREAD_H__
#define __THREAD_H__

#ifdef __cplusplus
extern "C" {
#endif

/* Define to prevent recursive inclusion
-------------------------------------*/
#include "types.h"





typedef    struct _mutex
{
    pthread_mutex_t        mutex;
}mutex_t;


typedef    struct _cond
{
    pthread_cond_t        cond;
}cond_t;


typedef    pthread_t        tid_t;
typedef    pthread_attr_t    attr_t;
typedef    void*    (* thread_fun_t)(void*);


typedef    struct _thread
{
    tid_t            tid;
    cond_t            *cv;
    int32_t            state;
    int32_t            stack_size;
    attr_t          attr;
    thread_fun_t    fun;
}thread_t;



/* mutex */
extern    int32_t        mutex_init(mutex_t    *m);
extern    int32_t        mutex_destroy(mutex_t    *m);
extern    int32_t        mutex_lock(mutex_t    *m);
extern    int32_t        mutex_unlock(mutex_t    *m);


/* cond */
extern    int32_t        cond_init(cond_t    *c);
extern    int32_t        cond_destroy(cond_t    *c);
extern    int32_t        cond_signal(cond_t *c);
extern    int32_t        cond_wait(cond_t    *c,mutex_t *m);



/* thread */
/* 线程的创建，其属性的设置等都封装在里面 */
extern    int32_t        thread_create(thread_t *t);
//extern    int32_t        thread_init(thread_t    *t);

#define    thread_join(t, p)     pthread_join(t, p)
#define    thread_self()        pthread_self()
#define    thread_sigmask        pthread_sigmask


#ifdef __cplusplus
}
#endif

#endif
/* END OF FILE
---------------------------------------------------------------*/

3,thread.c

#include "thread.h"




/* mutex */
int32_t        mutex_init(mutex_t    *m)
{
    int32_t        ret = OPER_OK;

    if((ret = pthread_mutex_init(&m->mutex, NULL)) != 0)
        ret = -THREAD_MUTEX_INIT_ERROR;

    return ret;
}


int32_t        mutex_destroy(mutex_t    *m)
{
    int32_t        ret = OPER_OK;

    if((ret = pthread_mutex_destroy(&m->mutex)) != 0)
        ret = -MUTEX_DESTROY_ERROR;

    return ret;
}



int32_t        mutex_lock(mutex_t    *m)
{
    int32_t        ret = OPER_OK;

    if((ret = pthread_mutex_lock(&m->mutex)) != 0)
        ret = -THREAD_MUTEX_LOCK_ERROR;

    return ret;
}



int32_t        mutex_unlock(mutex_t    *m)
{
    int32_t        ret = OPER_OK;

    if((ret = pthread_mutex_unlock(&m->mutex)) != 0)
        ret = -THREAD_MUTEX_UNLOCK_ERROR;

    return ret;
}






/* cond */
int32_t        cond_init(cond_t    *c)
{
    int32_t        ret = OPER_OK;

    if((ret = pthread_cond_init(&c->cond, NULL)) != 0)
        ret = -THREAD_COND_INIT_ERROR;

    return ret;
}



int32_t        cond_destroy(cond_t    *c)
{
    int32_t        ret = OPER_OK;

    if((ret = pthread_cond_destroy(&c->cond)) != 0)
        ret = -COND_DESTROY_ERROR;

    return ret;
}



int32_t        cond_signal(cond_t *c)
{
    int32_t        ret = OPER_OK;


    if((ret = pthread_cond_signal(&c->cond)) != 0)
        ret = -COND_SIGNAL_ERROR;

    return ret;
}




int32_t        cond_wait(cond_t    *c,mutex_t *m)
{
    int32_t        ret = OPER_OK;

    if((ret = pthread_cond_wait(&c->cond, &m->mutex)) != 0)
        ret = -COND_WAIT_ERROR;

    return ret;
}