【发布时间】:2018-09-27 16:03:55
【问题描述】:
所以我尝试使用mutex_init()、mutex_lock()、mutex_unlock() 进行线程同步。
我目前正在尝试以循环方式调度线程(但一次可能运行超过 1 个线程)并且我将线程的当前状态设置为 TASK_INTERRUPTIBLE,然后唤醒另一个 PID 的线程,我有一个列表。
为了我的逻辑,我需要遍历这个列表。
据我了解,我需要在访问其元素时锁定此列表,否则在我对其进行更改时,另一个线程可能会错过新条目。此外,由于一个互斥锁已锁定资源,其他互斥锁无法解锁它,直到原始互斥锁释放它。
但是,我仍然不确定我是否正确锁定了它。 (我在调用schedule()之前释放锁,然后重新锁定)
我在一个线程中本地声明一个互斥锁并锁定列表。在我当前的线程锁定之后
mutex_lock(&lock);
然后我遍历列表,直到我找到一些东西(或者如果它没有找到任何东西就结束),然后解锁。
mutex_unlock(&lock);
我认为在迭代时锁定是合法的。不过,我从未见过这样的例子。
另外,进程在持有互斥锁时处于 (TASK_UNINTERRUPTIBLE) 状态是否正常?
编辑:我将根据以下答案添加更多信息。
我的程序有可能在单核虚拟机上运行。因此,我不想冒险使用spin_lock() 进行无限轮询。
我正在尝试维护具有特定 ID 的线程之间的调度。例如,如果有 4 个线程。 2 个在“A”组中,2 个在“B”组中。我只允许在每组中运行 1 个线程。但是我在给定集合中的线程之间切换。但是,集合'A'中的线程不应切换到集合'B'中的任何线程
(我知道内核调度器不会是完美的,所以大致切换就可以了)。
我对 TASK_STATE 的推理:
1) 创建的初始线程正在运行。
2) 如果同一组中的另一个线程正在运行(并且这个线程在给定时间内没有执行)。设置其他线程为TASK_INTERRUPTIPLE,同时调用schedule(); 注意:每组中可以有超过 2 个线程,但为了简单起见,我们现在只考虑 2 个。
3)如果已经执行了足够的时间,则将此任务设置为TASK_INTERRUPTIPLE,将同一组中的其他任务设置为TASK_RUNNING,同时调用schedule();
所有这些逻辑都发生在我访问某些被(现在)全局互斥锁锁定的数据结构时。我在调用schedule() 之前解锁了互斥锁,然后立即重新锁定。在我的逻辑部分完成后,我完全解锁了互斥锁。
这种方法有什么根本错误吗?
【问题讨论】:
-
“但是,我仍然不确定我是否正确锁定它。” - 是您为您的程序定义“正确性”术语。代码如此之少,很难说什么是正确的,什么不是。 “进程在持有互斥锁时处于 (
TASK_UNINTERRUPTIBLE) 状态是否正常?” - 是的,在等待时持有互斥锁是可接受的。也就是说,您最好避免这种行为,但如果您需要,在等待期间持有互斥锁并没有错。 -
Re,“我在本地声明了一个互斥锁。”这听起来不太好。除非两个或更多线程尝试锁定 same 互斥体,否则锁定互斥体无效。如果“本地”的意思是“在一个局部变量中”,那么其他线程如何访问同一个互斥锁?
-
这里显示一些代码怎么样?你在问,“我做对了吗?”但你只是粗略地描述了你在做什么,实际上并没有描述你是如何做的。
标签: linux multithreading kernel-module