带锁的python问题
A python issue with locks

我有一段代码试图暂停特定的操作。 我有一个暂停应用程序的方法和另一个方法,它在一定的超时值后恢复应用程序。 至 ...

python多线程性能
python multiple thread performance

我有一个服务器有10个CPU内核,当我运行以下代码时,一个线程,其中一个cpu内核使用率为100%:def fun():1:pass但是当我使用5个线程运行时...

queue.get()只返回一个项目
queue.get() returns only one item

我正在构建一个小嗅探器,以便在我的网络中接收设备的答案。 我宁愿通过实现Scapys Packet类的answers()方法解决这个问题,但是这不起作用......

python:multiprocessing.dummy使用imap_unordered通过增长/修改列表进行迭代
python: multiprocessing.dummy using imap_unordered to iterate thru a growing/modifying list

摘要我想使用多个线程来处理列表。 在处理列表时,在某些条件下,可以添加列表,以便也应该处理新的添加。 ...

如何在每个线程的基础上创建日志记录/记录器?
how do I create logging / loggers on a per thread basis?

我相信我有一个独特的用例。 在大多数其他情况下,仅从所有线程登录到单个文件是完全令人满意的。 这对我不起作用,非常重要......

如何在Python代码继续运行时连续闪烁LED(或其他循环)
How to continuously flash LED (or other while loop) while Python code continues to run

我希望能够在我的主循环继续时连续闪烁LED。 我理解在以下代码中调用函数led_flash()时,脚本将停止,直到...

Python将参数传递给Thread类
Python pass argument to Thread class

Python初学者提问。 我在这里看到了许多以“旧”方式创建线程的例子,但没有那么多关于如何将参数传递给线程类的例子。 我的代码如下......我试过......

使用GIL之外的scipy例程
Using scipy routines outside of the GIL

这是一个与我想到的特定实现相关的一般性问题,关于在共享内存环境中使用设计用于GIL内部的python例程是否安全。 ...

Python3并发未来似乎不起作用
Python3 concurrent future doesn't seem to work async

我是python的新手,只是尝试一个简单的线程示例。 但我无法解释自己为什么这段代码同步工作:来自concurrent.futures导入ThreadPoolExecutor导入时间def ...

获取AttributeError:'int'对象在尝试运行基本线程程序时没有属性'start'
Getting AttributeError: 'int' object has no attribute 'start' when trying to run a basic thread program

我是线程的新手,正在执行一个非常基本的线程示例。 以下是我正在尝试执行的程序:import os import thread import threading def main():t1 = thread ....

如何在没有控制流卡在python的主循环中的情况下启动图形小部件?
How can I start a graphical widget without control flow getting stuck in its main loop in python?

我正在为即将到来的项目设计程序结构,我坚持以下问题:归结为其最重要的元素我的程序被分成两个文件logic.py和...

线程错误 - 太多args
threading error - too many args

我有一个python类,其中我有一个方法我想运行多个线程类OutageTool:def main(self):outages = [{'var1':1,'var2':2,},{'.. 。

Python:threading + curve_fit:内部例程的null参数
Python: threading + curve_fit: null argument to internal routine

我使用下面的代码有一些问题,它应该使用线程进行高斯拟合:从PIL导入图像导入numpy作为np来自scipy.optimize import curve_fit ...

在进程上存储对象?
Storing objects on a Process?

我想在multiprocessing.Process的子类上存储一个对象,如下所示:class TestProcess(Process):def __init __(self,foo):super(TestProcess,self).__ init __()...

在Python中,给定一个全尺寸图像目录,如何使用多个CPU内核生成缩略图?
In Python, given a directory of full-size images, how can I generate thumbnails using more than one CPU core?

我有一个16核的机器,但我目前的调整大小功能只使用一个核心,这对于大型图像目录来说效率非常低。 def generateThumbnail(self,width,height):“”“......

线程无法正常工作
Threading not working

我试图让这个小文件复制应用程序工作,显示进度条,但我不明白为什么这不起作用,因为它锁定gui同时更新仪表。 进口......

使用__stop停止的线程不会从threading.enumerate()中删除
threads stopped using __stop are not removed from threading.enumerate()

基本上,我有一些线程可能阻塞I / O但在某些情况下必须停止。 整个软件架构已经像这样设计,因此切换到多处理可以......

表现差异[已结束]
Differences in performance

任何人都可以解释为什么CODE 1优于CODE2,反之亦然:一些数据:具有4个核心的计算机,需要执行8个独立任务,每个任务需要大量处理,循环,......

多线程未初始化
Multiple Threads not initializing

我正在尝试创建一个优先级排队系统。 我设计了它并写了3个线程来做到这一点。 第一个线程从输出队列中取出项目,并根据优先级对...进行排序。

无法在X按钮上关闭多线程Tkinter应用程序
Cannot close multithreaded Tkinter app on X button

我的应用程序具有以下结构:从线程导入导入tkinter作为tk线程类MyWindow(tk.Frame):...#constructor,methods等def main():window = MyWindow()Thread(...

关于使用装饰器捕获错误
About catching errors with decorators

我试图用装饰器捕获线程错误:class cc:def catch_exceptions(job_func):@ functools.wraps(job_func)def wrapper(* args,** kwargs):try:...

动态输出时间进度
Dynamic Output of time progression

我已经看到很多关于如何在Python中基于迭代显示进度条的建议。 我的问题是有没有办法按时间做到这一点? 用例func()是非确定性函数,其...

父进程清理引发异常的线程
Parent process clean up thread that raised exception

我有一些包含两个对象的代码:class parent(object):def __init __():self.child = None def stuffParentDoes():while True:...

加入后Python线程没有关闭
Python threads are not closing after join

我正在使用类似的代码来控制rgb led条带,每隔几秒就会出现一个随机值,并且正在创建3个线程来控制3种单独的颜色。 从...导入时间...

删除Python NamedTemporaryFile而不关闭它
Python NamedTemporaryFile deleted without closing it

我正在使用ZOPE和Python 2.4,根据NamedTemporaryFile我遇到了问题。 我读到该文件在关闭时被删除,但不知怎的,我的文件被删除了,即使它不是。 我有 ...

杀死一个线程不起作用
Killing a thread does not work

我有一个简单的线程调用:aThread = threading.Thread(target = singleDriverThread,args =(d [0]))然后我启动它(aThread.start)当我需要停止我做的线程时:aThread。 join()但......

Python多处理功能
Python Multiprocessing function

我有一个函数,例如:launcher(usr_login,usr_password),它调用其他python脚本+ usr_login + usr_password作为参数。 请参阅:函数启动器(“login”,“pass”)将执行...

Python3多线程
Python3 multi threading

我正在研究Youtube下载程序脚本并遇到了多线程的困难。 我把url需要下载到一个队列中,然后通过新线程产生一个> 1。 以下是我...

python在后台运行任务,同时允许tkinter处于活动状态
python running task in the background while allowing tkinter to be active

当我的程序执行时,python GUI冻结。 这是我的主要代码。 我可以在做线程方面获得一些帮助吗? 所以执行发生在后台,我仍然可以使用“x”......

在Python 3中使用流选择器终止循环
Terminating loop using stream selector in Python 3

我在线程中运行了一些代码来等待使用套接字的传入客户端连接:import threading import socket import selectors class Server(threading.Thread):def __init __(self)...

Python无法找到类属性
Python cant find class attribute

为什么Factory.rdyq对继承的类不可见? bar.py import队列导入线程类工厂:name =“”rdyQ = Queue.Queue()dispQ = Queue.Queue()def __init __(self):...

如何实现动态数量的并发线程?
How to implement a dynamic amount of concurrent threads?

我正在启动并发线程做一些事情:concurrent = 10 q =队列中的j的队列(并发* 2)(并发):t = threading.Thread(target = doWork)t.daemon = True t.start()尝试: ...

如何在Python中修复这个线程的基本示例
How to fix this basic example of threading in Python

我正在尝试自学如何在Python中使用线程。 我想出了试图中断一个函数的基本问题,该函数将继续打印数字的正方形...

脚本不像在PyScripter中那样在命令提示符下运行
Script does not run on command prompt as in PyScripter

我正在PyScripter中开发一个脚本。 当我在PyScripter中运行它时运行得相当好。 但是,该脚本包含两个单独的线程(一个Thread对象和脚本的主流)。 当我 ...

Pandas使用Threadpool为大型数据集排名多个列
Pandas Rank Multiple Columns for huge dataset using Threadpool

我需要对数据帧的每一列进行排名。 我目前正在使用以下代码:for x in range(1,len(cols)):data [cols [x]] = data [cols [x]]。rank(ascending = 0)这适用于小数据集。 我有 ...

多线程python(使用_thread),什么都不做
Multithreading python (using _thread), doesn't do anything

首先,这里是我的两个python文件:sred.py:import _thread,time class Thread:def __init __(self,time:int,say:str):self.time = time self.say = say def create() :id = _thread ....

队列中的所有任务都已完成,但程序未继续
All tasks in Queue done, but program not continuing

我有一个这样定义的线程类:#!/ usr / bin / python import threading import子进程类PingThread(threading.Thread):ipstatus =''def __init __(self,ip):threading ....

如何在这里写地图句子来调用使用ThreadPool模块计算的数组?
How to write the map sentence here to call array to calculate with ThreadPool module?

我想用模块ThreadPool进行练习,为范围内的每个元素(1,100)添加2。 from multiprocessing.pool import ThreadPool array = range(1,100)class test():def myadd(self,x):...

Python中的Timer对象或类似的东西
Timer Object in Python or anything like that

我想在python中跟踪时间,以便在1周内重新运行模型。 我可以使用:import threading def learn_model():#stuff go here p = threading.Timer(604800,learn_model)...

Python:线程什么时候终止?
Python: when does a thread terminate? Oviously not (immediately) at return

我正在使用一个执行其工作并返回的threading.Thread()。 它的返回记录在print语句中,所以我确信会发生这种情况。 但是,依赖threading.active_count()和线程....

芹菜任务PENDING
Celery task PENDING

我基本上希望能够创建一个由一组链组成的和弦。 除了我似乎无法完成这项工作的事实之外,所有的子链都必须在和弦之前完成......

如何在python中不阻塞计时器等待输入?
How to wait for an input without blocking timer in python?

我需要每x秒打印一条消息,同时,我需要听取用户的输入。 如果按下'q',它应该杀死程序。 例如一些消息。 。 #指定后......

你可以执行一行作为python线程的目标吗?
Can you execute a single line as a target of a python Thread?

我有以下代码:errorThread = Thread(target = tkMessageBox.showerror(“Error”,b [-1] [z:]),args =())errorThread.daemon = True errorThread.start()我知道我可以做另一个......

每个线程独有的打印语句
Print statements unique to each thread

我想知道我是否可以打印一些每个线程独有的东西,所以就像每个print语句中的一个数字一样,告诉它正在形成哪个线程。 这是我的线程实现:import ...

如何实现线程在python中运行两个bash shell命令?
How to implement threading to run two bash shell commands in python?

我必须录制一个wav文件,同时我必须用sox进行分析。 我正在使用fifo类型文件进行此操作。 所以在这里我需要同时启动2个线程,但即使我使用...

为什么python线程模块中所有线程的名称相同?
why is name of all threads same in python threading module?

来自线程导入* def myfunc(i,name):打印(“这是”+ str(名称))for i in range(4):name = current_thread()。name t = Thread(target = myfunc,args =(我,名字,))t.start()...

启动一个新进程并读取该进程的输出
Start a new process and read that process's output

我有一个python脚本从管道bash脚本sudo beacon scan -b |读取数据 get.py我想消除使用bash管道并在python中编写所有内容。 我正试图开几个......

Python:跨线程共享类变量
Python: sharing class variables across threads

我有一个在一个类的许多实例之间共享的计数器(training_queue)。 该类继承了threading.Thread,因此它实现了run()方法。 当我调用start()时,我希望每个线程都增加...

Python time.sleep每个常规时间间隔和函数[重复]
Python time.sleep every regular time intervals and function

我需要每10秒钟开始执行一次函数foo(),并且foo()函数需要1到3秒之间的随机时间来执行。 导入时间导入datetime def foo():#......
1 2 3 4 5 6 7 8 9