个人中心
文章发布
退出
作者热门文章
- html - 出于某种原因，IE8 对我的 Sass 文件中继承的 html5 CSS 不友好？
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景？
25
4
代码:
#!/usr/bin/env python
import asyncio
import os
import socket
import time
import traceback
from aiohttp import web
from concurrent.futures import ProcessPoolExecutor
from multiprocessing import cpu_count
CPU_COUNT = cpu_count()
print("CPU Count:", CPU_COUNT)
def mk_socket(host="127.0.0.1", port=9090, reuseport=False):
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
if reuseport:
SO_REUSEPORT = 15
sock.setsockopt(socket.SOL_SOCKET, SO_REUSEPORT, 1)
sock.bind((host, port))
return sock
async def index(request):
icecast_index_path = os.path.abspath("../test/icecast/icecast_index.html")
print(icecast_index_path)
try:
content = open(icecast_index_path, encoding="utf8").read()
return web.Response(content_type="text/html", text=content)
except Exception as e:
return web.Response(content_type="text/html", text="<!doctype html><body><h1>Error: "+str(e)+"</h1></body></html>")
async def start_server():
try:
host = "127.0.0.1"
port=8080
reuseport = True
app = web.Application()
app.add_routes([web.get('/', index)])
runner = web.AppRunner(app)
await runner.setup()
sock = mk_socket(host, port, reuseport=reuseport)
srv = web.SockSite(runner, sock)
await srv.start()
print('Server started at http://127.0.0.1:8080')
return srv, app, runner
except Exception:
traceback.print_exc()
raise
async def finalize(srv, app, runner):
sock = srv.sockets[0]
app.loop.remove_reader(sock.fileno())
sock.close()
#await handler.finish_connections(1.0)
await runner.cleanup()
srv.close()
await srv.wait_closed()
await app.finish()
def init():
loop = asyncio.get_event_loop()
srv, app, runner = loop.run_until_complete(start_server())
try:
loop.run_forever()
except KeyboardInterrupt:
loop.run_until_complete((finalize(srv, app, runner)))
if __name__ == '__main__':
with ProcessPoolExecutor() as executor:
for i in range(0, int(CPU_COUNT/2)):
executor.submit(init)
#after the aiohttp start i want to execute more code
#for example:
print("Hello world.")
#in actual programm the ProcessPoolExecutor is called
#inside a pyqt5 app
#so i don't want the pyqt5 app to freeze.
问题是使用该代码我无法在 ProcessPoolExecutor 调用后执行代码。
我该如何解决？
我试图删除这部分:
try:
loop.run_forever()
except KeyboardInterrupt:
loop.run_until_complete((finalize(srv, app, runner)))
在 init() 方法中，但之后 aiohttp 服务器立即关闭。
编辑:如果我使用线程而不是 ProcessPoolExecutor，则会出现一个 aiohttp 错误:
RuntimeError: set_wakeup_fd only works in main threadRuntimeError: 线程中没有当前事件循环也许我可以使用 @ 签名直到 def 声明(我想)。
最佳答案
将 with 与执行器一起使用将导致您的进程阻塞，直到执行器中的作业完成；因为它们正在运行无限事件循环，所以它们永远不会完成，您的执行器也永远不会解除阻塞。
相反，只需使用执行器来启 Action 业，然后再运行你的东西。最终完成后，调用 .shutdown() 等待进程退出:
executor = ProcessPoolExecutor()
for i in range(0, int(CPU_COUNT/2)):
executor.submit(init)
# other code…
executor.shutdown()
关于Python aiohttp + 异步 : How to execute code after loop. run_forever()，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/71075317/
25
4
0
我认为这样的表达式会导致 Haskell 永远评估。但是 GHCi 和编译程序中的行为让我感到惊讶。 例如，在 GHCi 中，这些表达式一直阻塞到 I Control+C ，但不消耗 CPU。看起来像
就目前情况而言，这个问题不太适合我们的问答形式。我们希望答案得到事实、引用资料或专业知识的支持，但这个问题可能会引发辩论、争论、民意调查或扩展讨论。如果您觉得这个问题可以改进并可能重新开放，visit
如果可以的话，我想减少这段代码: class Alarm { internal static void isGreaterThanOrBelowValue(int min, int max,
我有以下问题: 我想创建一个批处理文件，循环访问一定数量的 IP 地址，以停止远程 PC 上的某个服务。 因为停止过程需要一些时间，所以我需要第二个循环来查询服务的状态并等待，直到服务达到“已停止”状
我已经完整地编写了“The Rust Programming Language”在线书籍中的程序，chapter 2 .我还进一步开发了它:通过添加一个简单的问题/响应，用户可以通过输入“y”再次玩游
这个人已经困扰了我一阵子了， 我们应该如何在集合中存储值或在for循环中映射？ (let [s #{}] (for [ i (range 10) j (range 1
mov ecx, 16 looptop: . . . loop looptop 这个循环会执行多少次？ 如果 ecx
我似乎无法找到一种在 Xtend 中表达以下内容而不诉诸 while 循环的好方法: for(int i = 0; i range(int stop) { range(0, stop) }
好吧，长话短说，我正在学习汇编，我正在尝试循环打印出 ascii 字符“0”-“9”。因此，我完成了我在示例中看到的所有基础知识，例如使用 pushad 和 popad 保存寄存器状态，分配堆栈空间，
我正在尝试为自己编写一个扑克计算器，我有一个 5 级深的 for 循环。 为此，我将 for 循环一个接一个地嵌套。我正在寻找一种方法来简单地使用一个循环(或函数)，它可以告诉我想去多少层。对于这个例
我有一本包含约 150,000 个键的字典。没有重复的键。每个 key 的长度为 127 个字符，每个 key 在 1-11 个位置上有所不同(大多数差异发生在 key 的末尾)。每个键的值是一个唯一
我正在尝试编写一个 Lisp 程序来实现与点和方 block 非常相似的棋盘游戏，这意味着我有两个玩家相互竞争但可以连续移动。我正在尝试实现最简单的 minimax 算法来实现这一点，没有 alpha
下面是我实现的代码的简要说明。 for 循环的复杂度应该是 O(n)。我只是无法弄清楚内部 while 循环的时间复杂度。 int x,n; // Inputted by the user.
我目前正在尝试使用 html 分词器 https://godoc.org/golang.org/x/net/html . 所以我想做的是:从 url 获取所有链接，如果 url 包含特定字符串 ->
我有 32 个文件(以相同的模式命名，唯一的区别是下面写的 $sample 编号)我想分成 4 个文件夹。我正在尝试使用以下脚本来完成这项工作，但该脚本无法正常工作，有人可以帮我使用以下 shell
我必须根据 where 条件在我的内部表上做一个循环，但根据我的程序模式，必须在运行时修改 where 条件的字段。 我知道在 SELECT 语句中这是可能的，但是当我在循环中执行此操作时出现错误。
我正在学习关于kdb数据库的q。我担心q中没有循环。 我需要写一个算法，用像C这样的冗长程序在几个嵌套的for循环中编写。但是在q中，我被无法循环的事实所困扰。 仅举一个具体的例子(很多)，我有一个简
我不明白为什么这段代码只循环一次然后退出？ 在 Ghci 中，我只能回答第一个循环，然后似乎变量 cont 设置为 false 并且我没有提示回答。 结果是: *Main> testLoop1 td1
我正在 Racket 中运行 for 循环，对于列表中的每个对象，我想执行两件事:如果该项目满足条件，(1) 将其附加到我的新列表中，(2) 然后打印列表。但我不知道如何在 Racket 中执行此操作
我正在尝试使用 matlab 并行包中的 parfor 循环。我和这个人有类似的问题:MATLAB parfor slicing issue? 。输出矩阵似乎没有被识别为切片变量。在我的具体情况下，我
我是一名优秀的程序员,十分优秀！