- mongodb - 在 MongoDB mapreduce 中,如何展平值对象?
- javascript - 对象传播与 Object.assign
- html - 输入类型 ="submit"Vs 按钮标签它们可以互换吗?
- sql - 使用 MongoDB 而不是 MS SQL Server 的优缺点
我对如何在 python/twisted 中编写异步代码感到有些困惑。假设(为了论证)我向世界公开了一个函数,该函数将接受一个数字,如果它是素数/非素数,则返回 True/False,所以它看起来像这样:
def IsPrime(numberin):
for n in range(2,numberin):
if numberin % n == 0: return(False)
return(True)
(只是为了说明)。
现在假设有一个网络服务器需要根据提交的值调用 IsPrime。对于较大的 numberin
,这将需要很长时间。
如果同时另一个用户要求一个小数的素数,有没有办法使用 react 器/延迟架构异步运行两个函数调用,以便在计算结果之前返回短计算的结果长计算?
如果 IsPrime 功能来自其他网络服务器,我的网络服务器将向其执行延迟 getPage,我了解如何执行此操作,但如果它只是一个本地函数怎么办?
也就是说,Twisted 能否以某种方式在对 IsPrime 的两次调用之间进行时间共享,或者这是否需要显式调用新线程?
或者,是否需要将 IsPrime 循环分成一系列较小的循环,以便将控制权快速传递回 react 器?
还是别的什么?
最佳答案
我觉得你现在的理解基本正确。 Twisted 只是一个 Python 库,您编写的使用它的 Python 代码可以正常执行,就像您期望的 Python 代码一样:如果您只有一个线程(和一个进程),那么一次只会发生一件事。 Twisted 提供的 API 几乎不会创建新的线程或进程,因此在正常情况下,您的代码会按顺序运行; isPrime
在第一次执行完成之前不能执行第二次。
仍然只考虑单个线程(和单个进程),Twisted 的所有“并发”或“并行性”都来自于这样一个事实,即 Twisted 不是阻塞网络 I/O(和某些其他阻塞操作),而是提供了以非阻塞方式执行操作的工具。这让您的程序可以继续执行其他工作,否则它可能会卡在等待阻塞 I/O 操作(例如读取或写入套接字)完成时什么也不做。
可以通过将它们分成小块并让事件处理程序在这些 block 之间运行来使事物“异步”。如果转换不会使代码更难理解和维护,这有时是一种有用的方法。 Twisted 为调度这些工作 block 提供了一个助手,cooperate
.使用此帮助程序是有益的,因为它可以根据所有不同的工作源做出调度决策,并确保有时间为事件源提供服务而不会产生明显的额外延迟(换句话说,您添加的作业越多) ,每个工作获得的时间越少,以便 react 器可以继续工作)。
Twisted 还提供了几个用于处理线程和进程的 API。如果不清楚如何将工作分成 block ,这些可能很有用。您可以使用deferToThread
在线程池中运行(线程安全!)函数。方便的是,此 API 返回 Deferred
最终将使用函数的返回值触发(或者如果函数引发异常,则使用 Failure
)。这些 Deferred 看起来像任何其他的,就使用它们的代码而言,它也可以从像 getPage
这样的调用中返回。 - 一个不使用额外线程的函数,只使用非阻塞 I/O 和事件处理程序。
由于 Python 不适合在单个进程中运行多个受 CPU 限制的线程,因此 Twisted 还提供了一个非阻塞 API 用于启动子进程并与子进程通信。您可以将计算卸载到此类进程以利用额外的 CPU 或内核,而不必担心 GIL 会减慢您的速度,这是分 block 策略和线程方法都没有提供的。处理此类进程的最低级别 API 是 reactor.spawnProcess
.还有Ampoule ,一个包,它将为您管理一个进程池,并为进程提供 deferToThread
的模拟,deferToAMPProcess
.
关于python - Twisted:使代码非阻塞,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/6117587/
在 Windows 世界中,什么是正确的名称。具有导出函数的老式 C++ DLL?不是 COM DLL,也不是 .NET DLL。我们以前通过调用 LoadLibrary() 和 GetProcAdd
目前我正在使用javaEE7,我有一个场景如下。在我的 JSF Web 应用程序中,我有一个事件监听器(不是 JSF 事件),当事件调用时,它会执行某些操作,然后将这些信息更新到我的 Web 应用程序
这不是 AJAX 请求/响应回调问题... 我正在使用 Dojo 1.5 构建网格。我正在尝试 dojo.connect具有功能的扩展/收缩按钮。我的问题是 grid.startup()在创建实际 D
非 Webkit Opera 是 very specific在某些功能中,因此通常通过 JavaScript 检测到 the following way . 但是,Opera Next 几乎是 Goo
我已查看以下链接中给出的所有日志,但未能找到 IP 地址: https://developer.couchbase.com/documentation/server/3.x/admin/Misc/Tr
我有一个命令行程序,它根据一组源文件生成一个我想在我的 Android gradle 构建 (A) 中使用的 jar 文件。这个命令行程序只是将一个 jar 文件存储在磁盘上的一个目录中。 我如何创建
下面的 htaccess 命令将所有非 www 转移到 http www RewriteEngine On RewriteCond %{HTTP_HOST} !^www\. RewriteRule ^
我正在使用自定义链接器脚本将内核镜像分为两部分。第一个是普通代码和数据,第二个是初始化代码和不再需要时将被丢弃的数据。初始化部分也不像内核本身那样在地址空间之间共享,因此如果 fork() 仍然存在(
这个问题在这里已经有了答案: Several unary operators in C and C++ (3 个答案) What is the "-->" operator in C++? (29
假设我有一个类设置如下: class A { public: virtual void foo() { printf("default implementation\n"); } }; c
#include using namespace std; int main(int argc, char *argv[]) { int i=-5; while(~(i)) {
近期,百度搜索引擎变化无常,很多企业站、行业站、门户站、论坛等站点遭到了降权,特别是比比贴分类信息网直接遭到了拔毛,这对于广大站长来说是一种打击,也是各个企业、行业的打击。 至今,很多网站已经恢复
我现在正在使用 IBM TPM v1332 + IBM TSS v1470 并尝试将一些基本关键字/密码存储到 TPM 上的非 volatile 内存中。我找到了两种方法。一种是创建一个密封对象并使用
我的 PHP 脚本中有一个正则表达式,如下所示: /(\b$term|$term\b)(?!([^)/iu 这与 $term 中包含的单词匹配,只要前后有单词边界并且它不在 HTML 标记内即可。 但
我想显示用户名称地址(请参阅 www.ipchicken.com ),但我唯一能找到的是 IP 地址。我尝试了反向查找,但也没有用: IPAddress ip = IPAddress.Parse(th
只有 UI 线程能够显示到屏幕上,还是其他线程也可以这样做? 最佳答案 不,您只能直接从 UI 线程访问 UI,但您可以编码来自其他线程的结果,例如使用 Control.Invoke 或 contro
我正在使用现代 Excel 滚动条(不是旧的 ActiveX 类型,即开发人员 > 插入 > 表单控件 > 滚动条)并且想检测它的值何时更改。我找不到有关此类对象的更改事件的任何信息。您可以在单击时分
当我使用这段代码时 IE 6 确实正确使用了指定的样式表,但所有其他浏览器在应该使用基本上声明的样式表时会忽略这两种样式表,如果您不是 IE,请使用此样式表。 有什么想法吗? 最佳答案 n
我想指定 2 mssql 表之间的关系。 付款类别和付款。 paymentcategory.id 加入 payout.category 列。 在 payout.json 模型中 我指定为外键:id,
我正在尝试制作非 volatile UDF,但似乎不可能。因此,这是我非常简单的test-UDF: Option Explicit Dim i As Integer Sub Main() i = 0
我是一名优秀的程序员,十分优秀!