python-multithreading相关内容
我正在编写一个Python网络爬虫程序,我想让它成为多线程的。现在我已经完成了基本部分,下面是它的功能: 线程从队列获取URL; 该线程从页面提取链接,检查链接是否存在于池(集合)中,并将新链接放入队列和池; 该线程将URL和http响应写入CSV文件。 但当我运行爬虫程序时,它最终总是被卡住,没有正确退出。我已经翻阅了Python的官方文档,但仍然一无所知。 代码如
..
我正在尝试使用Pycuda示例MultipleThreads在GPU上运行多个线程。当我运行我的python文件时,我收到以下错误消息: (/root/anaconda3/) root@109c7b117fd7:~/pycuda# python multiplethreads.py Exception in thread Thread-5: Traceback (most recent ca
..
我的API是在900ms内接收用户的文本,并将其发送到模型计算其长度(仅用于简单的演示)。我已经意识到了,但方式很难看。我将打开一个新的后台计划线程。API在主线程中接收到查询,将其放入由主线程和新线程共享的队列中。而新的线程将调度获取队列中的所有文本并将它们发送到模型。在模型计算它们之后,结果被存储在共享词典中。在主线程中,Get_Response方法会使用一个While循环来检查共享判定中的结
..
当我的程序执行时,python图形用户界面冻结。以下是我的主要代码。我可以在穿线方面得到一些帮助吗?所以执行是在后台进行的,如果我想结束执行,我仍然可以使用图形用户界面中的“x”按钮?当前我只要求用户关闭命令以结束程序。 if __name__ == "__main__": root = Tk() root.title('Log') root.geometry("
..
我正在运行webscraper class谁的方法名称是self.get_with_random_proxy_using_chain。 我正在尝试将多线程调用发送到同一URL,并且希望一旦有来自任何线程的结果,该方法就会返回响应并关闭其他仍在活动的线程。 到目前为止,我的代码看起来是这样的(可能很幼稚): from concurrent.futures import Thread
..
我在Python中线程化时遇到了一个问题,问题似乎是当我调用一个线程时,随后调用RAW_INPUT()会阻塞该线程。以下是最小的示例 import threading import time class tread_test(threading.Thread): def __init__(self): self.running = True thre
..
您好,我正在使用请求模块,我想提高速度,因为我有很多URL,所以我想我可以使用线程来获得更快的速度。以下是我的代码: import requests urls = ["http://www.google.com", "http://www.apple.com", "http://www.microsoft.com", "http://www.amazon.com", "http://www
..
我一直在尝试在python3中编写缓存代码,我希望避免线程和进程的并发问题。 我一直使用threading表示线程安全代码,使用multiprocessing表示进程安全。 我可以同时使用Lock Fromthreading和Lock Frommultiprocessing来解决问题。 但我想知道是否有一种“通用”锁来做这件事或类似的事情。 提前感谢;-) 推荐答案
..
我正在尝试弄清楚如何在运行“”.Serve_Forever()方法后在后台运行我的重载的定制BaseHTTPServer实例。 通常,当您运行时,方法执行将挂起,直到您执行键盘中断,但我希望它在继续脚本执行的同时在后台服务请求。请帮帮忙! 推荐答案 您可以在其他线程中启动服务器:https://docs.python.org/2/library/thread.html 所以是这
..
我看到了e.g. here使用Event停止线程的示例,我认为布尔标志可以完成此工作。 活动 class MyThread(threading.Thread): def __init__(self): self._please_stop = threading.Event() def run(self): while not self
..
我想从master script同时运行两个或多个Python脚本。这些脚本中的每一个都已经有并行运行的线程。例如,我运行 script1.py if __name__ == '__main__': pid_vav = PID_VAV('B2') t1 = threading.Thread(target=pid_vav.Controls) t1.daemon =
..
为了避免混淆,我编辑了问题: 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
..
我已经编写了一个脚本,它从文件中获取URL并同时向所有URL发送HTTP请求。我现在想限制每秒的HTTP请求数和每个接口的带宽(eth0、eth1等)。)在一次治疗中。有什么办法可以在Python上实现这一点吗? 推荐答案 您可以使用信号量对象,它是标准Python库的一部分: python doc 或者,如果您想要直接使用线程,可以使用Wait([Timeout])。 没
..
我有以下经过简化的代码: import concurrent.futures pool = concurrent.futures.ThreadPoolExecutor(8) def _exec(x): return x + x myfuturelist = pool.map(_exec,[x for x in range(5)]) # How do I wait for my
..
我在这个问题上研究了很多,但问题是无法弄清楚如何使用python3发送多线程POST请求 names = ["dfg","dddfg","qwed"] for name in names : res = requests.post(url,data=name) res.text 在这里我想发送所有这些名字,并且我想使用多线程来提高速度。 推荐答案 解决方
..
我想知道是否有任何方法可以调用一个python脚本并在不同的线程中完全启动该程序,这样主程序(调用者)就不必等到被调用的脚本执行完毕。到目前为止,我已经尝试了subprocess和os.system,但这两个都会延迟,直到脚本执行完毕。 main.py os.system('"F:second.py"') //continue the rest of the code without
..
我有以下打印函数的线程。 from threading import Thread from random import * import time def PrintRandom(): rand = random() time.sleep(rand) print(rand) if __name__ == "__main__": Thread(target
..
我是Python的中间人,我想以并行模式运行几个相同的类实例,用于获取数据和为金融市场做出决策。为了继续我的想法,我运行下面的代码来看看Python是如何工作的,它似乎可以运行一次完整的第一类实例和第二类实例,我想并行运行它,我如何才能...? 以下是用于测试的一些示例代码.. import threading import time class thr(object): def _
..
请考虑以下代码: #! /usr/bin/env python3 import threading import time class MyThread(threading.Thread): def __init__(self): super().__init__() self._quit_flag = False def run(self
..
阅读http://bugs.python.org/msg160297,我可以看到Stephen White编写的一个简单脚本,它演示了该异常是如何导致python线程出错的 Exception AttributeError: AttributeError("'_DummyThread' object has no attribute '_Thread__block'",) in
..