2

我写了一个简单的程序来实现 master/worker 方案，其中 master 是主线程，worker 是由它创建的。

主线程向共享缓冲区写入内容，工作线程读取该共享缓冲区，对共享缓冲区的写入和读取由读/写锁组织。

不幸的是，这种方案肯定会导致主线程饿死，因为一次写入必须等待多次读取才能完成。一种可能的解决方案是增加主线程的优先级，因此如果它想写一些东西，它将立即访问共享缓冲区。

根据类似问题的一篇很棒的帖子，我发现可能SCHED_OTHER不允许在策略下操纵线程的优先级，可以改变的nice只是值。

我写了一个程序，让工作线程的优先级低于主线程，但它似乎无法正常工作。

void assignWorkerThreadPriority(pthread_t* worker)
{
    struct sched_param* worker_sched_param = (struct sched_param*)malloc(sizeof(struct sched_param));
    worker_sched_param->sched_priority =0; //any value other than 0 gives error?
    int policy = SCHED_OTHER;
    pthread_setschedparam(*worker, policy, worker_sched_param);
    printf("Result of changing priority is: %d - %s\n", errno, strerror(errno));
}

我有两个问题：

  1. 如何设置工作线程的好值以避免主线程饥饿。
  2. 如果不可能，那么如何将调度策略更改为允许更改优先级的策略。

编辑：我设法使用其他策略运行程序，例如SCHED_FIFO，我所要做的就是以超级用户身份运行程序

4

1 回答 1

1

当读写使用如此均匀时，您无法避免使用读/写锁的问题。你需要一种不同的方法。您需要无锁消息队列或独立工作队列或许多其他技术之一。

这是完成这项工作的另一种方式，我会这样做。工作人员可以拿走缓冲区并对其进行处理，而不是保持共享：

  • 写线程：
    • 创建工作项。
    • 锁定保护当前队列和队列指针的互斥体或关键部分。
    • 将工作项添加到队列。
    • 释放锁。
    • 可选地向条件变量或事件发出信号。另一种选择是让工作线程检查计时器上的工作。
  • 工作线程：
    • 创建一个新队列。
    • 等待条件变量或事件或其他信号，或等待计时器。
    • 锁定保护当前队列和队列指针的互斥体或关键部分。
    • 将当前队列指针设置为新队列。
    • 释放锁。
    • 继续处理现在的私有队列。
    • 当所有工作项完成时删除队列。
  • 现在写线程创建更多的工作项。当所有工作线程都有自己的队列副本可以处理时，它将能够平静地写入许多项目。

你可以修改这个。例如，一个工作线程可能会锁定队列并将有限数量的工作项移到它自己的内部队列中，而不是拿走整个队列。

于 2011-05-11T21:27:06.520 回答