我试图在Python结构中重新实现Java，但是看起来Java有一些有趣的方法：
offer(E e)将指定的元素插入到此优先级queue.peek()中，但不会删除此队列的头部，如果此队列是empty.poll()，则返回null，如果此队列为空，则返回null。。
这在Python的PQ中转化为什么？我在Python的版本中没有看到这些方法：
get()从queue.put()中移除并返回一个项，将项目放入队列中。
如果我的理解是正确的：- == get()
但不确定sure ()是否与put()相同。我们如何重新实现peek()呢？
浏览 3提问于2020-04-10得票数 0
回答已采纳
我正在用wxpython编写一个GUI应用程序。该应用程序使用yolo来检测路面破损。我使用进行训练和检测。加载yolo模型太耗时，因此GUI将冻结。因此，我希望在使用threading.Thread加载yolo模型时显示进度条。我可以使用主线程加载yolo模型，但在使用新线程加载yolo模型时出现异常。
错误：
Traceback (most recent call last):
File "C:\Program Files\Python36\lib\contextlib.py", line 99, in __exit__
self.gen.throw(type,
浏览 0提问于2020-07-16得票数 0
1回答
我有一个场景，在.net中有客户机需要连接到python服务器，该服务器为每个接受的客户端创建一个线程。然后，服务器和客户端在它们之间发送和接收数据，直到客户机断开连接并关闭特定的客户端线程。
这个场景适合ZeroMQ吗?如果符合，我应该使用什么模式来实现这个场景？(插座类型等)
浏览 3提问于2015-10-29得票数 1
1回答
我有一个Python应用程序，它使用wxPython和一些额外的线程。一个线程使用。在某些情况下，应用程序会冻结，因此您会看到不完整的GUI。我发现它挂在PIL.Image.open上。当我把debug prints放到PIL模块中时，我可以看到它有一次挂在这里，一次挂在那里... --我不能理解。这看起来完全没有关系。
在Python语言中，有没有线程可以做的事情，导致其他线程停在像import string这样没有问题的行上？或者，wxPython能够产生这样的影响吗？
浏览 1提问于2012-07-27得票数 1
1回答
读取过程输出
、、
我在python调试器( pdb )上编写了一个简单的包装器，我需要解析pdb的输出。但我在从进程管道中读取文本时遇到问题。
我的代码示例：
import subprocess, threading, time
def readProcessOutput(process):
while not process.poll():
print(process.stdout.readline())
process = subprocess.Popen('python -m pdb script.py', shell=True, universal_newli
浏览 7提问于2012-12-16得票数 2
回答已采纳
from concurrent.futures import ThreadPoolExecutor, wait, ALL_COMPLETED
def div_zero(x):
print('In div_zero')
return x / 0
with ThreadPoolExecutor(max_workers=4) as executor:
futures = executor.submit(div_zero, 1)
done, _ = wait([futures], return_when=ALL_COMPLETED)
#
浏览 0提问于2019-05-10得票数 9
另一个python进程是外部启动的，只知道流程标识符。这个外部进程不是从python进程启动的子进程。两个进程的路径可能是相同的。我如何与这个过程沟通？如何在这些进程之间轻松地发送python数据类型？
向你问好，查莱克
浏览 0提问于2013-08-21得票数 1
回答已采纳
4回答
我将python解释器嵌入到一个多线程的C应用程序中，对于应该使用什么API来确保线程安全，我感到有点困惑。
据我所知，在嵌入python时，在调用任何其他Python C API调用之前，需要由嵌入器来处理GIL锁。这是通过以下函数完成的：
gstate = PyGILState_Ensure();
// do some python api calls, run python scripts
PyGILState_Release(gstate);
但仅有这一点似乎还不够。我仍然会遇到随机崩溃，因为它似乎没有为Python API提供互斥。
在阅读了更多的文档后，我还补充道：
PyEval_
浏览 154提问于2012-05-17得票数 18
回答已采纳
我有一个python服务器和一个node.js客户机。问题是，当我重新启动node.js脚本时，它不会重新连接。
而且，我不明白的是，为什么python上有一个无限循环。我不能用事件来监听连接吗。
下面是服务器和客户端。
context = zmq.Context()
socket = context.socket(zmq.PAIR)
print("Binding socket to port: " + str(port))
socket.bind("tcp://*:%s" % port)
print("Connection has been esta
浏览 0提问于2018-12-14得票数 5
我正在用Django编写一个web应用程序，其中我必须与另一个并行运行的python套接字服务器共享一些数据。 我尝试过使用一个普通的python文件来存储全局变量。但是，因为这些服务器是两个不同的进程，所以它不能工作。(我对使用任何数据库都不感兴趣)
浏览 29提问于2021-02-12得票数 0
回答已采纳
1回答
我应该使用线程还是进程？
、、、、
我在raspberry pi上用python编写代码
while(true):
functionA
functionB
函数A基本上是一个以png格式捕获图像的命令。我不想让它成为阻塞功能。我希望我的代码继续函数B，同时函数A捕获图像并为下一次运行做好准备。
我对是使用线程还是进程感到困惑。
如果我必须使用线程，它什么时候停止？在函数A完成其执行后，它会停止一次吗？在这种情况下，每次启动线程时，我都需要调用start方法？或者我应该使用一个过程，我将如何去做它，意思是什么时候进程将停止。
浏览 1提问于2016-12-29得票数 3
回答已采纳
1回答
具体地说，我说的是Python。我试图通过查看对象的值而不传递它来破解一些东西(只是一点点)，我想知道使用线程本地来做这件事是否线程安全。另外，你是怎么做这样的事情的呢？
浏览 0提问于2010-09-26得票数 5
回答已采纳
我一直在大量使用queue.Queue，在这种情况下，我执行多个线程，例如使用concurrent.futures.ThreadPoolExecutor。
我从博客中读到，queue.Queue应该是线程安全的，但这是否意味着它是线程安全的，假设Python解释器一次只执行一个线程(GIL)，或者在使用multiprocessing的情况下也是线程安全的--在使用multiprocessing的情况下--通过使用子进程而不是线程来执行GIL？
浏览 3提问于2020-04-20得票数 1
回答已采纳
1回答
我有一个在python中使用线程的代码。每个线程如果满足一个条件，将创建2个新线程。现在的问题是活动线程总数超过了ubuntu 12.04支持的活动线程总数。现在，活动线程队列中的每个线程都需要空间来创建新的线程，然后它将终止。我的系统有8个CPU。现在我的代码陷入了死锁。
浏览 0提问于2012-12-18得票数 0
首先，将eventlet或gevent等绿色线程与来自标准库的python原生线程混合在同一python进程中是否安全？
其次，如果它是安全的，这是一个坏主意吗？
浏览 5提问于2012-03-10得票数 4
回答已采纳
2回答
Python :并发C++嵌入
、、、、
嵌入到c++中的python允许您同时运行n个python脚本吗？
我现在正在处理恐惧，那就是吉尔。我的项目需要至少两个线程的并发性，使用Python进行简单的输入将有助于简化代码。
将我的Python代码嵌入到处理线程的C++脚本中，会避免GIL造成的问题吗？
浏览 7提问于2014-08-20得票数 1
回答已采纳
通常，当进程分叉子进程时，如果子进程终止，它将接收SIGCHLD信号。但是，如果在应用程序主线程以外的线程中发生此分叉，父线程将不会收到任何消息。
我用Python在不同的GNU/Linux机器上测试它。全部是x86_64。
我的问题是:它是一种Python行为，还是POSIX标准中定义的行为？在这两种情况下，为什么会这样呢？
下面是一个重新生成这种行为的示例代码。
import signal
import multiprocessing
import threading
import time
def signal_handler(*args):
print "Sign
浏览 1提问于2016-05-25得票数 1
2回答
我正在尝试使用多处理库的Process模块对代码进行线程化，以获得更好的性能。 代码的主干是为它们所处理的每个线程创建字典，完成后，将字典求和并保存到一个文件中。资源的创建方式如下： histos = {}
for int i in range(number_of_threads):
histos[i] = {}
histos[i]['all'] = ROOT.TH1F objects
histos[i]['kinds_of'] = ROOT.TH1F objects
histos[i]['keys']
浏览 11提问于2021-04-12得票数 0
回答已采纳
1回答
我是python的新手，在以下方面需要帮助。
假设我有一些不断向Python控制台输出数据的代码，例如：
for x in range(10000): print x
然后，我希望能够输入各种命令，这些命令可能会立即影响输出。例如，我输入一个数字，使循环从这个数字重新开始，或者我输入step=2，这会改变步长，等等。
基本上，我希望代码在后台运行和打印，而提示符仍然可用。
这样的事情有可能吗？我猜输出将不得不发送到一个新的窗口，但我不确定这在实践中会如何工作。我现在不喜欢图形用户界面，因为我只想让事情尽可能简单。
浏览 0提问于2019-08-12得票数 0
这个解释了如何从Python启动单个外部程序，如何同时启动多个same程序(或线程)？
我的预期应用是一个视频幻灯片放映。我想同时启动一个图像序列播放器和一个音乐播放器
提前感谢
浏览 1提问于2011-07-10得票数 0
回答已采纳
我是Python新手，所以我需要一些帮助。
我创建了一个服务器
SocketServer.ThreadingTCPServer
但我的问题是:在两个线程之间有任何通信方式吗？
浏览 2提问于2011-06-09得票数 1
回答已采纳
我同时打开了两个python程序，我希望当我单击第一个应用程序中的一个按钮时，将一些信息“发送”到第二个应用程序。
我正试着通过来自PySide的信号来做。我知道如何通过这个小代码发送它：
from PySide.QtGui import *
from PySide.QtCore import *
from PySide import QtGui, QtCore, QtUiTools
class Foo(object):
pass
class MyWidget(QWidget):
mysignal = QtCore.Signal(int, str)
def __i
浏览 3提问于2015-12-10得票数 0
1回答
我重温了我5年前用python编写的应用程序的开发(这是我在python 2.7中的第一个有趣的项目/应用程序，而当我重新审视它的时候，我正挣扎着做好准备)。该应用程序有以下单元/模块：
(Control)Moved 从摄像机(数据采集模块-DAQ)获取数据，对数据进行处理，并确定电机是否应该移动，，执行器，(Actuator)displayed，数据，以及几个tk窗口上的激活开关。(显示)
那时(在python2.7中)，我为上面提到的每个单元开发了单独的模块。为每个单元生成了不同的线程，我使用一个队列来传递图像数据，以及control和Actuator模块之间的控制命令。
随着进程间通信的
浏览 3提问于2022-07-22得票数 0
回答已采纳
我正在尝试将一个计数器从python COM线程传递回wxpython tabpanel。任何人都有一个可行的解决方案。下面是我的一些代码：
这个类是从我的wxPython代码中分离出来的，但是它被调用并将数据发送到这个线程。
class Log_COM_thread(Thread): ............ def run(self):
`.............`
`int_log_cnt = int_log_cnt + 1`
`int_log.TabPanel.gauge.SetValue(int_log_cnt)`
`if i
浏览 0提问于2013-02-02得票数 1
回答已采纳
1回答
我正在寻找一种在Python中的多线程之间传递值(例如整数、数组)的方法。我知道这个任务可以通过使用Queue模块来完成，但是我对python和这个特定的模块都不是很熟悉。
我有以下场景:每个线程需要根据自己的数据或来自其他线程的数据进行一些计算。此外，每个线程都知道哪些其他线程持有特定作业所需的数据(所有线程都有一个包含所有线程的数组，因此任何线程都知道，对于任务X，他需要从该数组中的特定线程(行、列)获取数据)。
如何使用队列模块或其他技术(队列模块似乎适合这项工作)来完成线程之间的通信。任何帮助都是非常感谢的。非常感谢。
浏览 0提问于2013-03-20得票数 2
回答已采纳
我正在尝试创建一个图形用户界面，我将有2个按钮。开始按钮将触发我的python脚本并显示移动的图形。当我按下停止按钮时，图形应该退出，python应该停止。
当我点击start按钮时，我得到了想要的结果。但是它进入无限循环，停止按钮没有退出，停止按钮不会将代码带到装饰器，我的函数code.Clicking ()也不会执行。
以下是代码片段：
from flask import Flask, request, flash, url_for, redirect, render_template, session
from flask import render_template
浏览 3提问于2018-04-10得票数 2
1回答
我需要跨线程边界传递异常。
我正在使用嵌入到一个非线程安全应用程序中的python，它有一个线程安全调用，post_event( callable )，它从它的主线程调用callable。
我在一个单独的线程中运行一个pygtk gui，所以当一个按钮被点击时，我会发布一个带有post_event的事件，并等待它完成后再继续。但我需要调用者知道被调用者是否抛出了异常，如果是，就引发它。我不太担心回溯，只担心异常本身。
我的代码大致是：
class Callback():
def __init__(self,func,*args):
self.func=func
浏览 0提问于2009-06-01得票数 7
回答已采纳
#!/usr/bin/env python
from multiprocessing import Process
class Signprocess(Process):
"""docstring for SignThread"""
def __init__(self):
super(SignThread, self).__init__()
self.result = False
def run(self):
self.result = True
print 123
process= Signp
浏览 3提问于2015-10-20得票数 3
回答已采纳
Python:如何将每个子线程运行的时间轮询到父线程？因此，在特定的时间框架之后，我可以调用一个新线程。
浏览 4提问于2014-07-18得票数 0
回答已采纳
在Django中，我有一个简单的测试用例失败：
模型(app/models.py)：
from django.db import models
class M(models.Model):
condition = models.CharField(max_length=80, db_index=True)
测试(app/tests.py)：
from django.test import TestCase
import threading
import time
from app.models import M
def insert():
time.sleep(0.3)
浏览 2提问于2012-06-27得票数 1
回答已采纳
2回答
昨天我把一个11.10盒升级到12.04。今天上午，我尝试运行apt-get升级程序，并遇到以下情况：
sudo apt-get upgrade
[sudo] password for brian:
Reading package lists... Done
Building dependency tree
Reading state information... Done
The following packages have been kept back:
linux-generic linux-headers-generic linux-image-generic
T
浏览 0提问于2012-04-27得票数 3
1回答
这是一个常识问题，很快就会变成一个项目。我有一个脚本，试图用已知的盐暴力破解sha1。在这个应用程序中，盐是已知的。不管怎样，脚本运行得很好，它是一个python脚本。当我运行它时，它占用了我可用的16个内核中的1个。我也想利用所有的16个核心来进行暴力破解！我稍微修改了一下脚本，并在这里使用了一个示例来利用多个内核，但它们并没有被完全使用。
这种解析化的东西对我来说是非常新的，我不确定如何在python中使用它(更不用说任何脚本语言了)。
在python中，利用所有可用于暴力破解哈希的核心的最佳方式是什么，比如MD5？
基本上我现在所拥有的是这样的.(注意改述后的代码)
from mult
浏览 3提问于2012-12-19得票数 2
回答已采纳
1回答
我目前正在设计一个基于软件UI。
我已经创建了第一个python脚本，用作我的主要源代码。
下面是我的脚本
import OneTouchToolLogs
import UserInterface
import wx
import XML_Parse
import threading
if __name__ == '__main__':
#Init the logging - Tools and also logcat scenario
Logs = OneTouchToolLogs.Logging()
LogFileName = Logs.Log
浏览 0提问于2014-06-13得票数 0
我想知道，在python3队列中没有超时的阻塞get什么时候可以不返回。
python3 声明：
Queue.get(block=True，timeout=None)
从队列中移除并返回项。如果可选的args块为true，超时为None (默认值)，则在必要时阻止它，直到项目可用为止。如果超时值为正数，它最多会阻塞超时秒，如果在此时间内没有可用项，则会引发空异常。否则(块为false)，如果一个项立即可用，则返回一个项，否则引发空异常(在这种情况下忽略超时)。
对我来说，这意味着没有参数的get()将等待队列中的一个元素，然后才返回，因此总是返回一个不是None的值。在底部的示例中，给
浏览 3提问于2017-05-03得票数 2
嗯，我最初想到的是如何确定或是否是线程安全的。pubsub可能有点棘手或复杂，但pydispatcher似乎很容易实现。然后我开始想知道如何判断python模块是否是线程安全的。有什么启发式吗？
浏览 2提问于2011-09-19得票数 9
Python 2.7 我想发表3次和interval=3秒。 所以我尝试使用time.sleep(3)，然后发布。 我的代码如下： for i in range(3):
print(i)
mqttc.publish("test", "hello")
time.sleep(3) 结果应该是这样的： 0
(Publish)
(delay 3 sec)
1
(Publish)
(delay 3 sec)
2
(Publish)
(delay 3 sec) 但真正的结果是： 0
(delay 3 sec)
1
(delay 3 sec)
2
(
浏览 31提问于2019-08-28得票数 0
回答已采纳
1回答
我是python的新手。我想了解python execute signal .I是如何开始阅读官方文档的。下面的语句没有任何意义 1. 1.Python信号处理程序不会在低级(C)信号处理程序中执行。相反，低级信号处理程序设置一个标志，该标志告诉虚拟机在稍后的点(例如，在下一个字节码指令处)执行相应的Python信号处理程序。 2."Python信号处理程序总是在主解释器的主Python线程中执行，即使信号是在另一个线程中接收到的。“有人能帮帮我吗？
浏览 15提问于2021-01-24得票数 1
我正试图建立一个系统来管理一个小型的数据库，并用来自网络的数据填充它。
我希望在后台运行这个过程，但是仍然有一些与它交互的方式。
我怎么用Python来做这件事呢？
我想知道如何在两种情况下做到这一点：
来自同一个python脚本，类似于daemon = task.start()，后面跟着daemon.get_info()或daemon.do_something()
从shell (通过另一个我可以制作的程序) myclient get_info或myclient do_something
有人能给我一些关键的概念去调查吗？
编辑:我刚读过，套接字编程(正如他上一个例子中所指出
浏览 2提问于2020-05-06得票数 0
当我需要软件之间的对话框时，我使用MailSlots和Delphi作为软件(在MailSlots上使用相同的程序)。现在，我需要做同样的事情，但是在Python和上，也需要在Linux上。那么:在同一台计算机上运行的Python编写的软件之间进行通信的最佳方式是什么？对于一些防火墙问题，我倾向于避免IP对话。当我测试它时，我不想要所有的DIsk文件共享解决方案。
所以简单地说：
2 Python软件在同一台计算机上需要对话。
无IP
没有磁盘文件共享。
浏览 6提问于2011-03-17得票数 1
回答已采纳
2回答
我有几个问题要问。
我有一个算法，它将在python中生成一些必须显示在表单上的图片。为此，我使用了PyGt。我的问题是:我应该在哪里运行我的代码？从初始化器的右边？在这种情况下，根据我的测试，表单不会出现。
我是否应该在构造函数中设置一个计时器，以便在半秒后启动算法？
运行算法会冻结我的表单，从而无法看到图片本身吗？我不介意按钮、复选框等在计算过程中冻结，只要当前图片仍然可见。
我应该使用像c#的OnFormLoad()这样的东西吗?如果是，我如何设置它?通过连接()？
在python上线程是如何工作的？我听说过，但我不太确定，这是一个痛苦的处理。是吗?在c#中，它就像写4行
浏览 0提问于2009-11-11得票数 1
回答已采纳
我有一个python，它通过套接字接收来自C++应用程序的数据，并更新它的字段(Qt网格对象)和一个Q线程中的3D模型。更新字段在线程中正常工作，但是当我向线程中添加一个函数来更新3D模型(使用更新字段中的值)时，我会得到一个“致命的Python错误: GC对象已经跟踪”。代码运行了几毫秒，但随后由于错误而崩溃。三维模型的创建和转换是基于Mayavi.mlab软件包的。
我还尝试将更新3D模型函数放在另一个线程中，但这并没有消除错误。为什么这个错误会发生/我如何摆脱它？
主要代码：
self.PSRThread = 0 # thread for the PSR server
浏览 2提问于2016-07-14得票数 0
这是我第一次在python中使用多线程。我在python2.7.9中发现了许多与多线程和多处理相关的文档，并对进行了研究。但我不知道如何实现我的应用程序。我有一个基于self.count的应用程序，在下面的代码是5。我必须创建一个5个线程或进程，当我调用d.sum(1,2)时，这应该是在5个不同的线程中调用sum函数并并行执行，用线程名和结果更新结果字典中的结果。
现在我现在的方法是连续发生的。，但我希望使用线程或进程将其作为并行处理。请帮助实现这一点。
提前谢谢。代码片段是非常感谢的。
到目前为止我有密码。
class Base(object):
def __init__(self
浏览 2提问于2015-11-28得票数 1
我有一个用Python编写的多线程应用程序，其中一个线程“负责”GUI，另一个线程是工作线程。然而，在某个时刻，工作线程在处理数据的过程中，会发出一个带有连接到GUI线程中的display_image()函数的QString的信号。display_image()函数要求用户输入一行文本。
我的问题是，如何让辅助线程等待数据处理，直到display_image()函数返回值，即直到用户按下OK按钮？
GUI.py
class GUI(QMainWindow):
def __init__(self, parent=None):
super, etc
self.worker =
浏览 1提问于2011-10-24得票数 2
回答已采纳
1回答
在Python语言中，当我没有引用我用threading.Thread(target=worker_method)创建的线程时，这是不是很糟糕？有没有可能垃圾收集器对它做了什么，从而影响了我的应用程序的稳定性？
浏览 3提问于2012-05-02得票数 1
回答已采纳
2回答
我有一个机器人项目，基本上是一个路径跟踪问题。在PC机上，用Python3.65实现了一种参考生成算法。该算法利用室内GPS数据，利用这些不断更新的数据计算机器人车的参考路径。当然，算法运行在一个而True：.框架中。该算法只有在采样频率相当高的情况下才能很好地工作，比如0.001s。但是，问题是，在计算引用路径之后，需要通过Serial.write()逐字节将路径信息写入PC的串口。这个serial.write()函数仍然是一个for循环。这个写入过程非常慢(超过0.02s，16个字节)。如果for循环包含在while True: framework中，则如下所示：
while True:
浏览 1提问于2018-06-27得票数 1
回答已采纳
我创建了一个关于熊猫数据的全球变量。我希望子进程能够访问全局数据，但子进程似乎无法获得全局变量。
data = pd.DataFrame(data = np.array([[i for i in range(1000)] for j in range(500)]))
def get_sample(i):
print("start round {}".format(i))
sample = data.sample(500, random_state=i)
xs = sample.sum(axis=0)
if i < 10:
浏览 0提问于2019-08-04得票数 1
回答已采纳
我在我的Delphi应用程序中使用Python为Delphi组件托管Python脚本。我想创建通过脚本运行的后台任务。
是否可以创建即使脚本执行结束也继续运行的线程(而不是继续运行的宿主进程)。我注意到，如果执行脚本结束，并且有线程在运行，程序就会卡住。但是，如果我等到线程完成时，一切都会正常进行。
我正在尝试使用“线程”标准模块来处理线程。
浏览 4提问于2008-09-15得票数 1
我有一个交互式控制台应用程序，我需要使用Python处理它(发送命令和接收输出)。应用程序是由另一个启动的，我不能从Python脚本启动它。
是否可以连接到已在运行的控制台应用程序并访问其stdin/stdout？
理想情况下，该解决方案应该同时适用于Windows和Unix，但仅Windows版本也会有所帮助。目前，我正在使用在这里找到的解决方案，但它不允许连接到现有进程。
感谢您的意见，
浏览 1提问于2013-01-18得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
