Linux sem_trywait实现sem_timedwait

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了Linux sem_trywait实现sem_timedwait，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含2256字，纯文字阅读大概需要4分钟。

内容图文

• sem_timedwait说明

          int sem_timedwait(sem_t *sem, const struct timespec *abs_timeout);

          其中第2个参数 struct timespec *abs_timeout要求为绝对时间，如果手动将系统时间往后修改会导致sem_timedwait长时间阻塞

• sem_trywait说明

         int sem_trywait(sem_t *sem);

         sem_trywait与 sem_wait() 类似，若信号不可用，则返回错误(errno 设置为EAGAIN)而不是阻塞

• sem_timedwait自定义实现

#include <stdio.h>
#include <pthread.h>
#include <unistd.h>
#include <sys/time.h>
#include <sys/types.h>
#include <semaphore.h>
#include <errno.h>


unsigned long long GetClockTimeMS( void )
{
    unsigned long long time;
    struct timespec curTime;

    clock_gettime(CLOCK_MONOTONIC_RAW, &curTime);
    time = curTime.tv_sec;
    time *= 1000;
    time += curTime.tv_nsec/1000000;
    return time;
}

unsigned long long GetClockTimeUS( void )
{
    unsigned long long time;
    struct timespec curTime;

    clock_gettime(CLOCK_MONOTONIC_RAW, &curTime);
    time = curTime.tv_sec;
    time *= 1000000;
    time += curTime.tv_nsec/1000;
    return time;
}

unsigned long long GetClockTimeNS(void)
{
    unsigned long long time;
    struct timespec curTime;

    clock_gettime(CLOCK_MONOTONIC_RAW, &curTime);
    time = curTime.tv_sec;
    time *= 1000000000;
    time += curTime.tv_nsec;
    return time;
}

int SleepEx(int us)
{
    struct timeval timeout;

    timeout.tv_sec = us/1000000;
    timeout.tv_usec = us%1000000;
    if(-1 == select(0, NULL, NULL, NULL, &timeout))
    {
        return errno;
    }
    return 0;
}

int WaitEvent(sem_t *hEvent, unsigned int milliseconds)
{
    int ret;
#if 0
        struct timespec timeout = { 0 };
#ifdef _DEBUG
        ret = clock_gettime(CLOCK_REALTIME, &timeout);
#else
        clock_gettime(CLOCK_REALTIME, &timeout);
#endif//_DEBUG
        timeout.tv_sec += (milliseconds / 1000);
        timeout.tv_nsec += ((milliseconds % 1000) * 1000000);
        if (0 == sem_timedwait((sem_t *)hEvent, &timeout))
        {
            return 0;
        }
        return errno;
#else
        unsigned long long timeout = milliseconds*1000;//微秒
        unsigned long long beg = GetClockTimeUS();
        unsigned long long cur;
        do 
        {
            if (0 == sem_trywait((sem_t *)hEvent))
            {
                return 0;
            }
            ret = errno;
            if (EAGAIN != ret)
            {
                return ret;
            }
            cur = GetClockTimeUS();
            if (cur - beg >= timeout)
            {
                break;
            }
            SleepEx(1);
        } while (1);
        return ETIMEDOUT;
#endif
}

int main(void)
{
    sem_t event;
    sem_init(&event, 0, 0);
    unsigned long long begUS = GetClockTimeUS();
    WaitEvent(&event, 2000);
    printf("end %llu..\n", GetClockTimeUS() - begUS);
    return 0;
}

 

内容总结

以上是互联网集市为您收集整理的Linux sem_trywait实现sem_timedwait全部内容，希望文章能够帮你解决Linux sem_trywait实现sem_timedwait所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

---