当前位置：文江博客话题详情

将 POSIX 信号量的值增加超过 1

发布于 2024-09-14 04:18:31 字数 230 浏览 6 评论 0原文

我有这样的要求，其中我必须将 POSIX 信号量的值增加超过 1。

显然，POSIX 规范中没有办法做到这一点。没有类似于 sem_getvalue() 的 sem_setvalue()。我不想仅仅因为这个限制而回到 System V 信号量。

有没有其他方法可以实现这一点？或者我必须采用 System V 方式吗？

我正在 GNU/Linux 上使用 C 进行编程。

非常感谢。

原文

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

So尛奶瓶 2024-09-21 04:18:31

我有这样的要求，其中我必须将 POSIX 信号量的值增加 1 以上。
有没有其他方法可以实现这一点？或者我必须采用 System V 方式吗？

那么你的问题到底是什么？如何实现接口不支持的东西？或者如何使用 POSIX 创建行为类似于信号量的结构？

如果这是稍后的事情，那么在诉诸 SysV 之类的重型武器之前，您始终可以使用 pthread_mutex_t/pthread_cond_t 对来实现几乎任何多线程同步原语，包括信号量。

例如，未经测试：

typedef cool_sem {
    pthread_mutex_t guard;
    pthread_cond_t cond;
    int count;
} cool_sem_t;

void init( cool_sem_t *s )
{
    pthread_mutex_init( &s->guard, 0 );
    pthread_cond_init( &s->cond, 0 );
    s->S = 0;
}

void incr( cool_sem_t *s, unsigned delta )
{
    assert( s );
    pthread_mutex_lock( &s->guard );
    s->S += delta;
    pthread_cond_broadcast( &s->cond );
    pthread_mutex_unlock( &s->guard );
}

void decr( cool_sem_t *s, unsigned delta )
{
    assert( s );
    pthread_mutex_lock( &s->guard );
    do {
        if (s->S >= delta) {
            s->S -= delta;
            break;
        }
        pthread_cond_wait( &s->cond, &s->guard );
    } while (1);
    pthread_mutex_unlock( &s->guard );
}

I have this requirement wherein I have to increment the value of a POSIX semaphore by more than 1.
Is there any alternative way to accomplish this? Or will I have to go the System V way?

So what is your question really? How to implement something not supported by interface? Or how to create a structure behaving like semaphore using POSIX?

If this is later, before resorting to heavy guns like SysV, you can always use the pthread_mutex_t/pthread_cond_t pair to implement pretty much any multi-threading synchronization primitive, semaphore included.

E.g., untested:

typedef cool_sem {
    pthread_mutex_t guard;
    pthread_cond_t cond;
    int count;
} cool_sem_t;

void init( cool_sem_t *s )
{
    pthread_mutex_init( &s->guard, 0 );
    pthread_cond_init( &s->cond, 0 );
    s->S = 0;
}

void incr( cool_sem_t *s, unsigned delta )
{
    assert( s );
    pthread_mutex_lock( &s->guard );
    s->S += delta;
    pthread_cond_broadcast( &s->cond );
    pthread_mutex_unlock( &s->guard );
}

void decr( cool_sem_t *s, unsigned delta )
{
    assert( s );
    pthread_mutex_lock( &s->guard );
    do {
        if (s->S >= delta) {
            s->S -= delta;
            break;
        }
        pthread_cond_wait( &s->cond, &s->guard );
    } while (1);
    pthread_mutex_unlock( &s->guard );
}

回复收藏 0 原文