使用信号量阻塞线程,直到所有其他线程都运行了一定次数的临界区
首先，我们需要了解什么是信号量，以及它在阻塞线程方面的作用。
信号量（Semaphore）是一个计数器，用于控制对共享资源的访问。在多线程编程中，信号量可以用于确保某个线程只执行一定次数的临界区，并在所有其他线程完成执行后允许该线程继续执行。
在 Python 中，可以使用 multiprocessing 模块中的 Semaphore 类来实现信号量。以下是一个使用信号量阻塞线程的示例：
import multiprocessing
# 创建信号量
semaphore = multiprocessing.Semaphore(5)
# 创建子进程
def worker():
# 尝试获取信号量
semaphore.acquire()
# 执行临界区
print("Worker process executing critical section")
# 释放信号量
semaphore.release()
# 创建子进程
p = multiprocessing.Process(target=worker)
# 启动子进程
p.start()
# 等待子进程结束
p.join()
# 所有其他线程都已完成执行
print("All threads have completed their critical sections")在上面的示例中，我们创建了一个信号量 semaphore，并将其初始化为 5。然后创建了一个子进程，并在子进程中使用 acquire() 和 release() 方法来访问和释放信号量。最后，我们启动子进程并等待它完成执行。当所有其他线程都执行了一定次数的临界区后，我们打印出最终的输出。
需要注意的是，在多线程编程中，使用信号量来阻塞线程是一种非常常见的技术，但需要注意线程同步和死锁等问题。
相关·内容
3回答
使用1和0初始化信号量的差异
java、java.util.concurrent
请告诉我初始化为1和0的信号量有什么区别。如下所示：
public static Semaphore semOne = new Semaphore(1);
和
public static Semaphore semZero = new Semaphore(0);
浏览 10提问于2014-08-29得票数 25
回答已采纳
1回答
如何使用锁确保方法同时运行一定次数
java、multithreading、concurrency、synchronization、locking
我知道在Java中，为了确保每个线程一次只运行一段代码，只需使用synchronized关键字。也就是说，
synchronized (getClass()) {
// expensive work
}
然而，我宁愿只在有足够的RAM可用的情况下执行昂贵的工作。也就是说，假设我有10个线程在运行，在代码的expensive work部分，它占用了50 MBs的内存。假设我根据JVM可以使用的最大内存进行计算，并意识到我可以同时安全地运行其中的5个线程。
那么，如何正确地使用Locks、Concurrency或.wait()/.notify()来确保expensive work只运行设置的
浏览 0提问于2013-09-06得票数 1
回答已采纳
3回答
计数信号量与二进制信号量的区别
operating-system、semaphore
计数和二进制信号量的区别是什么？
我在某处看到的是，两者都可以控制请求资源的N个进程。两者都有taken状态和Free状态。
二进制信号量和计数信号量可以保护多少资源有限制吗？
两者都只允许一个进程一次使用一个资源...
还有其他区别吗？上述属性是否正确？
浏览 3提问于2012-06-05得票数 30
回答已采纳
2回答
Spring @Async取消并启动？
spring、spring-mvc、asynchronous、transactions、spring-annotations
我有一个spring MVC应用程序，用户可以通过点击按钮来启动报告生成。此过程可能需要几分钟~ 10-20分钟。我在服务调用周围使用了spring @Async注释，以便异步生成报告。而我弹出一条消息给用户，指出作业当前正在运行。现在我想要做的是，如果另一个用户(Admin)可以通过按钮启动报告生成，该按钮应该取消/停止当前运行的@Async任务并重新启动新任务。为此，我调用
.. ..
future = getCurrentTask(id); // returns the current task for given report id
if (!future.isDone())
浏览 6提问于2014-01-13得票数 3
2回答
超过许可证上限:信号量
java、multithreading、semaphore
public class semaphoreTest {
static LinkedList<Integer> integerLinkedList = new LinkedList<>();
static Semaphore semaphore = new Semaphore(1);
static Object lock = new Object();
public static void main(String[] args) throws InterruptedException {
Thread t1 = new Thread(new Runnable
浏览 1提问于2017-01-20得票数 2
回答已采纳
2回答
Python的信号量永远挂起
python、multithreading、semaphore
我试图在我的程序中同时做一些事情，并控制同时打开的进程的数量(10)。
from multiprocessing import Process
from threading import BoundedSemaphore
semaphore = BoundedSemaphore(10)
for x in xrange(100000):
semaphore.acquire(blocking=True)
print 'new'
p = Process(target=f, args=(x,))
p.start()
def f(x):
... # do som
浏览 6提问于2014-03-23得票数 1
回答已采纳
我有一个有趣的问题。使用Qt处理C++项目。跨平台项目，但在Win上开发。
我有一个C风格的回调函数。它必须是C风格的，我别无选择。在C风格回调函数中完成的工作非常重要，而且对时间敏感。因此，我有一些Qthread线程来帮助处理工作负载。
我没有使用Qt线程的运行方案，而是使用QThread文档底部解释的QThreads。
为了清楚起见，我这样使用QThread：
QThread *thread = new QThread;
Worker *worker = new Worker;
worker->moveToThread(thread);
thread->start();
QMe
浏览 1提问于2012-04-14得票数 1
3回答
当临界区在循环中时，我需要调用睡眠来避免死锁吗？
linux、semaphore、shared-memory
下面是来自这两个程序的相关代码片段。基本上，使用者从共享缓冲区中将整数出队，而生产者从命令行中将整数入队。如果在循环结束时没有调用睡眠，就会发生死锁。也就是说，这两个进程似乎都在等待信号量。我不明白这是怎么发生的，我希望能有一个解释。另外，请让我知道是否有合适的替代方案来替代我的“睡眠，让其他进程获得机会”的解决方案。我的直觉告诉我应该有，这是我决定发布这个问题的主要原因。
消费者：
while (get_success == 0) {
// critical section
sem_wait(semaphore);
if (*top != *bottom || *empty ==
浏览 0提问于2012-03-07得票数 3
1回答
同步两个并行工作的类
java、serial-port、synchronize
你好，我正在创建一个读写串行端口的程序。在程序开始时，我将类命名为ReadSerialPort、WriteSerialPort和JWakeup。
我的问题是:当我从JWakeup向串口写入一些东西时，我想等待串口响应。
public class MainClass{
public static void main(String args[]){
new ReadSerialPort().OpenSerialPort();
new WriteSerialPort().OpenSerialPort();
new JWakeup().setVisible(true);
浏览 2提问于2013-02-07得票数 1
回答已采纳
3回答
如果semaphore.acquire()获得InterruptedException，需要使用semaphore.relase()吗？
java、semaphore、interrupted-exception
从Java的java.util.concurrent.Semaphore文档中，我不太清楚如果semaphore.acquire()阻塞线程，然后被InterruptedException中断会发生什么。信号量的值是否减少了，是否需要释放信号量？
目前我使用的代码如下：
try {
// use semaphore to limit number of parallel threads
semaphore.acquire();
doMyWork();
}
finally {
semaphore.release();
}
或者，当在acquire()过程中发生Interrupte
浏览 3提问于2012-08-24得票数 13
回答已采纳
2回答
信号量和SemaphoreSlim使用最佳实践
c#、multithreading、semaphore
我在这个类的顶部创建了一个信号量实例。
public static SemaphoreSlim _zReportSemaphore = new SemaphoreSlim(1, 500);
在我的代码中，我需要检索和发送一些数据。
while (_isRunning)
{
try
{
xBsonDocument = null;
//I think its very clear in this line...
MongoDBDAO.xGetInstance().GetZReportData(ref xBsonDocument);
浏览 2提问于2016-03-30得票数 0
回答已采纳
2回答
什么是Java中的阻塞信号量？
java、semaphore
根据我的理解，阻塞信号量被初始化为零而不是1，其工作方式是任何执行P(S)操作的线程都会阻塞，直到V(S)首先释放为止。
如果有人能用一个例子来解释这个机制，我们将不胜感激。
浏览 0提问于2018-02-22得票数 2
回答已采纳
3回答
什么是关键部分？
c++、critical-section
我只想弄清楚这件事。假设我使用的是EnterCriticalSection的windows api。我用EnterCriticalSection(&criticalsection);给他们都打了电话
这是多线程的线程函数
void thread (){
//enter critical section (part 1)
data
//leave critical section
///more data 1
//entercritical section (part 2)
//more data 2
//leave critical section
}
一旦一个线程进入临界区
浏览 3提问于2011-04-10得票数 7
回答已采纳
2回答
多处理中的外部和内部__main__变量定义
python、multithreading、multiprocessing、python-multiprocessing
我有以下代码：
import multiprocessing
import time
import os
# WHEN SEMAPHORE IS DEFINED HERE THEN IT IT WORKS
semaphore = multiprocessing.Semaphore(1)
def producer(num, output):
semaphore.acquire()
time.sleep(1)
element = "PROCESS: %d PID: %d PPID: %d" % (num, os.getpid(), os.getppid())
p
浏览 4提问于2015-09-03得票数 1
回答已采纳
2回答
peterson的解决方案如何解决有界等待？
multithreading、operating-system
《恐龙》一书说，临界区问题的解决方案必须满足互斥、进步和有界等待
这是书中Peterson的解决方案中描述的过程的结构：
do {
flag[i]=True;
turn=j;
while (flag[j] && turn==j);
// critical section
flag[i]=False;
// remainder section
} while (True);
我不明白这是如何解决有限等待问题的。有界等待表示，一个进程进入临界区的次数是有限制的，这样就不会出现进程饥饿。但是这里没有计数器，在这个解决方案中，进程之间只共享这两个变量：
in
浏览 0提问于2016-05-25得票数 2
1回答
python线程模块中对信号量的需求
python、multithreading
Python线程模块没有实现真正的并行编程。线程之间相互交换。那么，信号量是必要的吗？信号量用于向应同时处理的其他线程发送信号。我认为它只在多进程中有用。为什么信号量类在线程模块中？
浏览 1提问于2015-05-14得票数 1
2回答
允许一个线程运行，一个线程等待，然后删除其他线程
java、concurrency
我有一个观察者，可以多次调用。如果观察者的onChange方法仍在运行，则应该等待第二个调用，并且应该忽略后面的调用。
我使用了这个：
Semaphore semaphore = new Semaphore(2,false);
...
public void onChange() {
if (!semaphore.tryAcquire()) return;
synchronized (semaphore) {
// do your stuff
semaphore.release();
}
}
这样可以吗？有没有更好的方法？
浏览 4提问于2012-02-01得票数 2
回答已采纳
1回答
Python -信号量可以从特定线程中解锁吗？
python、multithreading、semaphore
几周前，我开始学习Python。我想知道是否有可能解锁从特定线程获取的信号量。或者有没有其他的工具？
import threading, time
sem = threading.Semaphore
def thread1 (threadname):
#Code to do
#Condition thread1
time.sleep(0.001)
sem.acquire()
#Code 1
sem.release
def thread2 (threadname):
while (thread1.is_alive() == True)
浏览 4提问于2019-11-21得票数 2
回答已采纳
2回答
await Task.Run(() => semaphore.WaitOne())有问题吗？
c#、.net、multithreading、thread-safety、task-parallel-library
标题说明了一切。await Task.Run(() => semaphore.WaitOne());有什么问题吗？System.Threading.Semaphore不是线程仿射的，所以我认为不会有问题。我知道SemaphoreSlim类是可用的，但我需要进行跨进程同步，而SemaphoreSlim不能做到这一点。
或者我可以/应该创建我自己的自定义类型的WaitHandle
浏览 1提问于2014-04-17得票数 9
2回答
异常后信号量超时
c#、multithreading、try-catch、semaphore
我在管理来自多个模块的资源时遇到了一些问题，这些模块一次只能安全地访问一次。
所以我尝试了一个命名Semaphore，如下所示：
var semaphore = new Semaphore(1, 1, "_UGLY_SEMAPHORE_NAME_");
try
{
var signaled = semaphore.WaitOne(120000); // 2 minutes
if (!signaled)
{
return;
浏览 2提问于2014-03-13得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
活动推荐
腾讯云开发者
