blocking 相关问题

阻塞模式I / O阻塞发布线程,直到操作传输至少一个字节或发生错误或流结束。阻塞算法是指多线程环境中的操作,它暂时将对某些资源的访问限制为单个线程,从而阻止所有其他资源。目前尚不清楚该标签的用途。

为什么 robots.txt 文件应该阻止子文件夹,但也阻止一些随机文件

我通过将文件添加为文件夹,为我的网站索引了一些奇怪的 URL。这里有一个示例 URL https://www.plus2net.com/python/tkinter-scale.php/math.php 我有一个文件 tkinter-scale.php 但是...

回答 1 投票 0

SQL Server 2005 睡眠 SPID 阻塞另一个 SPID

我发现我的 SQL Server 数据库有许多休眠进程,看起来这些休眠 SPID 之一正在阻塞另一个进程,并且该进程也被挂起... 有人可以解释一下吗

回答 3 投票 0

Azure 存储帐户分区冗余存储阻止

我正在使用使用分区冗余存储的 Azure 存储帐户。当我写入文件并关闭它时,Azure 似乎会阻止该文件,直到它被复制为止。有没有某种程序可以排除...

回答 1 投票 0

Puma 如何允许 IO 等待并行完成以提高 MRI 的吞吐量?

来自 Puma 的自述文件: 在 MRI 上,有一个全局 VM 锁 (GVL),可确保一次只有一个线程可以运行 Ruby 代码。但如果你正在进行大量阻塞 IO(例如对外部 API 的 HTTP 调用...

回答 2 投票 0

如何让 Kotlin 中的 runBlocking 正常工作?

我的目标是让 loadInformationFromFirestore(从 Firestore 数据库读取数据)在执行其后的代码(此处只是 Timber 日志记录消息)之前完成。当我跑步时

回答 1 投票 0

在 Kotlin 代码中,runBlocking 不会阻塞

我正在尝试运行一个名为 getGroupSummaries 的函数,并让它在下一个代码运行之前完成。 getGroupSummaries 声明如下: 暂停乐趣 getGroupSummaries(groupInfo:

回答 1 投票 0

为什么 MPI_Bsend() 是一个阻塞函数?

如以下定义所示,MPI_Bsend() 是一个阻塞 MPI 函数。但这违背了我们对“封锁”一词的普遍理解。所以出现了这些问题:形容词是否“阻塞...

回答 1 投票 0

Python 的 `print()` 函数是阻塞函数还是非阻塞函数?

我正在尝试加快脚本的处理时间,在某些配置中可能会通过 print() 将大量输出转储到控制台。 Python的print()函数是阻塞还是非阻塞...

回答 2 投票 0

进程在写入管道时挂起

我正在编写一个进程间通信的程序,但是我遇到了一个问题,即使管道中有足够的空间,写入操作也会阻塞进程。 我正在使用遥控器...

回答 1 投票 0

写入未满的管道会阻塞 C 中的进程

我在处理涉及实施管理进程间通信的程序的作业时遇到问题。 简化上下文: 有一个管道,我们称之为 A,还有 16 个进程...

回答 1 投票 0

阻塞 IO 与非阻塞 IO [已关闭]

有一次,我偶然看到 Indy 简介文章,从那时起我就一直在思考阻塞 IO 与非阻塞 IO。 正在寻找一些描述优点和缺点的好文章...

回答 2 投票 0

领先拦截者查询

设置不计数 去 选择 SPID、阻止、替换(替换 (T.TEXT, CHAR(10), ' '), CHAR (13), ' ' ) AS BATCH 进入#T 来自 sys.sysprocesses R 交叉应用 sys.dm_exec_sql_text(R.SQL_HANDLE) T 去 与

回答 1 投票 0

Celery 工作线程挂起,没有任何错误

我有一个用于运行 celery 工作人员的生产设置,用于向远程服务发出 POST / GET 请求并存储结果,它每 15 分钟处理大约 20k 任务的负载。 问题是

回答 4 投票 0

Python 子进程块

我的模块子进程有问题;我正在从 Python 运行一个脚本: subprocess.Popen('./run_pythia.sh', shell=True).communicate() 有时它只是阻塞并且没有完成......

回答 2 投票 0

subscribe()方法是否阻塞?

我从 Project Reactor 开始,我无法理解为什么这段代码无限地打印“Hello”并且从不返回 Disposable 对象。 Flux Flux = Flux.generate(sink -&... 我从 Project Reactor 开始,我无法理解为什么这段代码无限地打印“Hello”并且从不返回 Disposable 对象。 Flux<Object> flux = Flux.generate(sink -> sink.next("Hello")); Disposable disposable = flux.subscribe(System.out::println); disposable.dispose(); System.out.println("This doesn't print"); 我认为,当调用 subscribe() 方法时,它必须立即返回 Disposable 对象,如果我愿意,我可以使用该对象取消订阅。我知道这个 subscribe 方法中的代码在同一个线程中运行,如果我在 delayElements 调用之前替换 subscribe 方法,那么下面的代码将起作用,因为它在单独的守护线程中运行,所以可以解释为什么吗?它是否停止在 subscribe 方法并且不返回 Disposable 以及是否有任何方法可以通过调用 subscribe 方法来管理订阅?是否可以类比delayElements方法,在单独的线程中执行,并且调用subscribe方法的结果立即返回Disposable? 我找不到这个问题的具体答案。在我看到的所有示例中,要么是有限数据流,要么使用了delayElements方法。 是的,subscribe()在这个特定场景中会阻塞。 Reactor 是并发无关的,这意味着默认情况下它不会对您强制执行任何线程/异步性,并在调用线程(在本例中为主线程)上执行管道。 您可以使用 subscribeOn 或 publishOn 显式更改此设置,也可以使用 delayElements 等某些运算符隐式更改。 Flux<Object> flux = Flux.generate(sink -> sink.next("Hello")).publishOn(Schedulers.parallel()); Disposable disposable = flux.subscribe(System.out::println); disposable.dispose(); System.out.println("This doesn't print");

回答 1 投票 0

如何中止winsock阻塞调用?

我在 C++ 中使用 Winsock 2,并且想知道如何使我的服务器停止从客户端连接读取。读取线程在 recv() 中被阻塞,我不知道如何中止它。做到这一点的一种方法是...

回答 3 投票 0

Stream 是否有可用的阻塞读取方法?

我正在用 C# 编写一个应用程序,以通过 Web 应用程序远程打开 Docker 容器的终端。我需要读取 Docker.NET 客户端返回的流并通过...转发读取的字节...

回答 1 投票 0

python 请求阻止发布 mqtt 消息

我正在开发一个从两个来源获取数据的程序: 来自前端的传入 mqtt 消息 (paho) 和 来自 RestAPI 的数据(请求) 传入的 mqtt 消息触发对 R 的请求...

回答 1 投票 0

在 Spring Boot 应用程序中使用网络请求功能将 Suspend 关键字视为多余

我一直在深入研究 Kotlin 协程,发现挂起函数可以简化使用 Kotlin 和协程时异步和非阻塞代码的创建。在 Android 中

回答 1 投票 0

如何通过Javascript实现单线程“阻塞io”模型?

我们都知道nodejs服务器是基于“单线程非阻塞io模型”工作的。 如果您是一名讲师,您会如何解释“非阻塞 io 模型”的需要

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.