python-multithreading相关内容

多线程的Python Web Crawler被卡住了

我正在编写一个Python网络爬虫程序,我想让它成为多线程的。现在我已经完成了基本部分,下面是它的功能: 线程从队列获取URL; 该线程从页面提取链接,检查链接是否存在于池(集合)中,并将新链接放入队列和池; 该线程将URL和http响应写入CSV文件。 但当我运行爬虫程序时,它最终总是被卡住,没有正确退出。我已经翻阅了Python的官方文档,但仍然一无所知。 代码如 ..
发布时间:2022-04-17 16:23:16 Python

使用Pycuda多线程

我正在尝试使用Pycuda示例MultipleThreads在GPU上运行多个线程。当我运行我的python文件时,我收到以下错误消息: (/root/anaconda3/) root@109c7b117fd7:~/pycuda# python multiplethreads.py Exception in thread Thread-5: Traceback (most recent ca ..
发布时间:2022-04-17 16:21:15 Python

如何在不使用While循环进行检查的情况下检查在另一个调度线程中共享和编辑的变量状态是否已更改

我的API是在900ms内接收用户的文本,并将其发送到模型计算其长度(仅用于简单的演示)。我已经意识到了,但方式很难看。我将打开一个新的后台计划线程。API在主线程中接收到查询,将其放入由主线程和新线程共享的队列中。而新的线程将调度获取队列中的所有文本并将它们发送到模型。在模型计算它们之后,结果被存储在共享词典中。在主线程中,Get_Response方法会使用一个While循环来检查共享判定中的结 ..
发布时间:2022-04-17 16:19:04 Python

在后台运行任务,同时允许tkinter处于活动状态

当我的程序执行时,python图形用户界面冻结。以下是我的主要代码。我可以在穿线方面得到一些帮助吗?所以执行是在后台进行的,如果我想结束执行,我仍然可以使用图形用户界面中的“x”按钮?当前我只要求用户关闭命令以结束程序。 if __name__ == "__main__": root = Tk() root.title('Log') root.geometry(" ..
发布时间:2022-04-17 16:16:40 Python

当我得到结果时,Python ThreadPoolExecutor关闭所有线程

我正在运行webscraper class谁的方法名称是self.get_with_random_proxy_using_chain。 我正在尝试将多线程调用发送到同一URL,并且希望一旦有来自任何线程的结果,该方法就会返回响应并关闭其他仍在活动的线程。 到目前为止,我的代码看起来是这样的(可能很幼稚): from concurrent.futures import Thread ..
发布时间:2022-04-17 16:13:48 Python

用于线程和进程的Python3锁定(&Q)

我一直在尝试在python3中编写缓存代码,我希望避免线程和进程的并发问题。 我一直使用threading表示线程安全代码,使用multiprocessing表示进程安全。 我可以同时使用Lock Fromthreading和Lock Frommultiprocessing来解决问题。 但我想知道是否有一种“通用”锁来做这件事或类似的事情。 提前感谢;-) 推荐答案 ..

在后台运行Python HTTPServer并继续执行脚本

我正在尝试弄清楚如何在运行“”.Serve_Forever()方法后在后台运行我的重载的定制BaseHTTPServer实例。 通常,当您运行时,方法执行将挂起,直到您执行键盘中断,但我希望它在继续脚本执行的同时在后台服务请求。请帮帮忙! 推荐答案 您可以在其他线程中启动服务器:https://docs.python.org/2/library/thread.html 所以是这 ..
发布时间:2022-04-17 16:02:21 Python

停止线程:标志与事件

我看到了e.g. here使用Event停止线程的示例,我认为布尔标志可以完成此工作。 活动 class MyThread(threading.Thread): def __init__(self): self._please_stop = threading.Event() def run(self): while not self ..
发布时间:2022-04-17 16:00:46 Python

线程和信息传递--如何

为了避免混淆,我编辑了问题: one.py import threading count = 5 dev = threading.Thread(name='dev', target=dev,args=(workQueue,count,)) dev.setDaemon(True) dev.start() workQueue = Queue.Queue(10) queueLock.acqu ..
发布时间:2022-04-17 15:57:26 Python

在Python上限制每秒的HTTP请求数

我已经编写了一个脚本,它从文件中获取URL并同时向所有URL发送HTTP请求。我现在想限制每秒的HTTP请求数和每个接口的带宽(eth0、eth1等)。)在一次治疗中。有什么办法可以在Python上实现这一点吗? 推荐答案 您可以使用信号量对象,它是标准Python库的一部分: python doc 或者,如果您想要直接使用线程,可以使用Wait([Timeout])。 没 ..

在不等待脚本执行的情况下调用脚本

我想知道是否有任何方法可以调用一个python脚本并在不同的线程中完全启动该程序,这样主程序(调用者)就不必等到被调用的脚本执行完毕。到目前为止,我已经尝试了subprocess和os.system,但这两个都会延迟,直到脚本执行完毕。 main.py os.system('"F:second.py"') //continue the rest of the code without ..

未并行处理的Python线程

我是Python的中间人,我想以并行模式运行几个相同的类实例,用于获取数据和为金融市场做出决策。为了继续我的想法,我运行下面的代码来看看Python是如何工作的,它似乎可以运行一次完整的第一类实例和第二类实例,我想并行运行它,我如何才能...? 以下是用于测试的一些示例代码.. import threading import time class thr(object): def _ ..
发布时间:2022-04-17 15:41:10 Python

了解python线程错误

阅读http://bugs.python.org/msg160297,我可以看到Stephen White编写的一个简单脚本,它演示了该异常是如何导致python线程出错的 Exception AttributeError: AttributeError("'_DummyThread' object has no attribute '_Thread__block'",) in ..
发布时间:2022-04-17 15:37:39 Python