我正在学习Python及其多处理。
我用mian()在main.py中创建了一个项目，在包simulator/下在模块simulation.py中创建了一个a_simulation。
其症状是，当程序与print("hello\n")一起运行时，main.py中的测试语句在mian()定义之前被多次执行，指示打印之前的内容，包括列表的创建都被多次执行。
我想我对python的相关问题不太了解。我可以知道出现这种症状的原因是什么吗?在创建这样的项目时，python的最佳实践是什么？我已经把密码和终端打印都包括了。谢谢!
编辑:忘了提到我正在macOS上使用anaconda运行它，
浏览 2提问于2022-07-11得票数 0
回答已采纳
2回答
我已经创建了一个小音频播放器，它可以在我指定的网站上查找有声读物的章节，下载并播放它。唯一的问题是，我不能暂停它。播放我使用的os.system("afplay chapter.mp3")的mp3文件
我考虑过创建一个包含os.system调用的线程，但我非常确定我不能以这种方式暂停它。如果线程是一个循环，我可以只锁定一个变量，当我准备恢复时，它需要访问和解锁。但是由于这个线程只有一行代码，这似乎是不可能的。我还研究了如何创建一个进程并将SIGSTOP发送给它。但由于某些未知的原因，这不会起作用。
import os, signal
from multiprocessing i
浏览 0提问于2012-07-17得票数 0
回答已采纳
我对线程和进程很陌生。我一直在努力理解asyncio。在研究asyncio on 时，我遇到了multiprocessing、threading、signal和subprocess模块。
我一直在想，为什么名称subprocess模块是这样命名的。为什么模块没有被称为进程。下面的“潜艇”是什么意思？
编辑:遗忘加法
有一个Popen类，我假设'P‘代表过程。说：
Popen(.)：用于在新进程中灵活执行命令的类
难道Popen类的存在没有给出更多的理由来调用模块process而不是subprocess
浏览 1提问于2018-12-18得票数 0
回答已采纳
我目前正在写一个python脚本。
这里的最终目标只是导入pysam。但是，为了做到这一点，我首先导入了一套称为galaxy的工具，pysam就是其中之一。
如果在命令行中先加载galaxy，然后进入python交互shell，然后导入pysam，则导入成功。
但是，我的脚本是这样的：
#!/usr/bin/env python
import subprocess
subprocess.call("module load galaxy/galaxy", shell=True)
subprocess.call("module load ngs-ccts/tabix/0
浏览 1提问于2014-06-13得票数 1
1回答
新的就像IIS一样，在应用程序崩溃和重启时以某种方式检测到。它是如何实现的？仅仅通过询问Windows进程是否仍然存在，或者一些更微妙的东西(比如RPC调用)？如果进程挂起导致HTTP超时，会发生什么情况？
浏览 4提问于2016-06-06得票数 0
我正在尝试创建一个python脚本来自动运行我的所有Django命令，但是因为os.system('python manage.py runserver')需要继续运行，所以脚本执行在os.system('python manage.py runserver')处停止并且不运行下一行。如何在os.system('python manage.py runserver')仍在运行的情况下运行下一行代码？ 我尝试使用python睡眠方法等待几秒钟，然后运行下一行，但不起作用。 下面是我的代码： import os, webbrowser, time
浏览 37提问于2018-12-26得票数 0
回答已采纳
1回答
我写了一个cgi脚本，它将使用os.system("firefox &")打开一个火狐窗口。
所以我的想法是，它将为我创建一个firefox窗口，然后为远程用户打印一个确认页面。
问题是它只在我关闭firefox窗口后才打印确认页。这特别令人费解，因为如果我在终端中运行脚本，而不是让apache运行它，它会像预期的那样立即打印确认html。
有没有人能提供一些见解，说明为什么我无法立即加载确认页面？
浏览 3提问于2012-02-10得票数 0
我用Python语言编写了一个大型程序，一个接一个地调用大量自定义模块的main方法。父脚本创建了一些公共资源，比如日志记录实例、数据库游标和文件引用，然后我将它们传递给各个模块。问题是，我现在需要通过subprocess.check_output调用其中一些模块，而我不知道如何在这些模块之间共享前面提到的资源。这个是可能的吗？
浏览 0提问于2013-09-29得票数 2
joblib文档包含以下警告：
在Windows环境下，重要的是保护代码的主循环，以避免在使用joblib.Parallel时递归生成子进程。换句话说，您应该编写如下代码：
进口..。def function1(.)：def function2(.)：.如果__name__ ==‘_。
任何代码都不应该运行在“if __name__ ==‘__main__”块之外，只有导入和定义。
最初，我认为这只是为了防止偶尔出现一个函数递归地传递给joblib.Parallel的奇怪情况，这意味着它通常是很好的实践，但通常是不必要的。然而，这对我来说是没有意义的，为什么这只会在Windows上成为
浏览 7提问于2015-04-09得票数 24
回答已采纳
我有一个服务器-客户架构。服务器是一个QtApplication，包含一个QThread。
我试图使用在multiprocessing中构建的python打开一个新的客户机进程，从QThread中打开一个新的客户机进程，从那个新的过程中打开一个新的QtApplication。这样，服务器和客户机都在运行QtApplications。
问题是，我得到了以下错误：
警告: QApplication不是在main()线程中创建的。
QApplication是在新进程的主线程中创建的，因此我不知道为什么会发生此错误。
浏览 2提问于2017-07-20得票数 0
我有一个PySide应用程序。我想创建一个小部件，我将在其中显示另一个应用程序(例如，SFML/Irrlicht/Ogre/无论是什么游戏，它将是独立的.exe而不是python脚本)，该小部件将作为该过程的主窗口。这个是可能的吗？
我不需要与该应用程序进行任何通信，我将通过套接字进行通信。
浏览 1提问于2012-12-23得票数 4
回答已采纳
def sample():
pass
Process(target=sample).start()
Process(target=sample).start()
上面的代码失败时出错：
尝试在当前进程完成其引导阶段之前启动一个新进程。这可能意味着您没有使用叉子进程启动子进程，并且忘记在主模块中使用正确的成语。
但这段代码运行良好：
def sample():
pass
if __name__ == '__main__':
Process(target=sample).start()
Process(target=sample).star
浏览 2提问于2015-12-11得票数 5
回答已采纳
我注意到，我可以访问子进程/目标之外的子进程中的函数和模块。所以，我在想，当我在python中创建一个子进程时，它是否复制了当前进程中的所有内容？为什么我可以访问子目标之外的函数和导入模块？
from multiprocessing import Process, Pipe
def test1():
return "hello"
def simpleChildProcess( childPipe ):
# simpleChildProcess can access test1 function
foo = test1()
浏览 0提问于2019-08-19得票数 4
1回答
我正在编写脚本的NodeJS服务器，需要散列用户密码，除了其他数据块，在数据库中存储它们之前。由于创建安全散列的数学密集型过程，以及需要完成的大量散列，我选择用C语言编写散列过程。
我的问题是:与为NodeJS创建本机插件相比，通过child_process.exec执行用C编写的散列过程会增加多少开销？
也就是说，每次需要对一段数据进行散列处理时，我都需要以这段数据作为参数来调用child_process.exec。
浏览 19提问于2017-01-26得票数 1
回答已采纳
1回答
我有一个Python程序，在某些条件下，应该会提示用户输入文件名。然而，有一个默认的文件名，我想提供，用户可以编辑，如果他们愿意。这通常意味着他们需要点击backspace键来删除当前的文件名，并将其替换为他们喜欢的文件名。
为此，我将Python3中的改编为：
def rlinput(prompt, prefill=''):
readline.set_startup_hook(lambda: readline.insert_text(prefill))
try:
return input(prompt)
finally:
浏览 1提问于2015-05-14得票数 1
回答已采纳
这是一个令人费解的问题，甚至很难命名，更不用说描述了。我将从基本事实开始，然后给出哪些背景信息可能是相关的。
考虑两个mongoengine文档模型：
class Bar(Document):
# ...
# field definitions
# ...
def bar_func(self):
pass # ...or some arbitrary code
class Foo(Document):
bar = ReferenceField(Bar)
下面是在我们的生产服务器上生成一个inconsistently的Attribut
浏览 2提问于2011-12-07得票数 3
回答已采纳
1回答
假设我们有一个典型的灯设置。当一个人请求一个用php编码的网页时，在Apache级别上会发生什么？Apache是否创建一个新的php实例来创建并返回该网页？或者在任何时候都有一个连续的php实例运行？
基本上，我认为它是如何工作的：
个人访问http://example.com/index.php
Apache接收到请求，展开php实例来创建页面。
页被创建，并发送回请求浏览器。
PHP实例已关闭
因此，只有一个php实例处理页面requests...Is --我的想法是正确的吗？
浏览 0提问于2013-10-01得票数 0
回答已采纳
我有一个名为control.py的模块，在其中我使用了以下简短的代码- def parallel_execution():
if __name__=="__main__":
process=multiprocessing.Process(target=worker_function) ##the worker_function has been defined appropriately
process.start()
process.join()
return
def main(main_args):
if
浏览 11提问于2020-07-09得票数 0
我正在寻找一种方法来创建一个Python程序来包装另一个Python程序。这就是我的意思：
while (otherProgram is waiting for raw_input):
send some text to the other program
这是至关重要的，我可以在两个单独的程序中这样做。
这里是另一个例子：
program1.py
text = raw_input()
print("You entered " + text)
text2 = raw_input()
print("Your second input was " + tex
浏览 8提问于2014-02-10得票数 0
回答已采纳
1回答
我的脚本在MKS Integrity (PTC) -lifecycle管理器中创建问题-创建问题后，问题ID仅显示在控制台响应中(或在图形用户界面中，但我不能选择)。
问题产生的方式
im createissue …
os.system('im createissue ...') # in python
响应类似于：
Editing fields ...
Adding attachments ...
Field Attachments: Attachment attachment.something: added
Adding field values ...
Submitti
浏览 14提问于2020-05-28得票数 0
在多处理和运行Windows下冻结的应用程序时，我需要一些实现日志记录的帮助。有几十个关于这个问题的主题，我花了很多时间回顾和测试这些问题。我还对进行了广泛的回顾，但我不知道如何在我的代码中实现这一点。
我创建了一个在Linux上运行良好的最小示例，但是在Windows上崩溃(即使没有冻结)。我创建的示例只是我所经历的许多迭代中的一个。
你可以找到。任何帮助，以使这个例子的工作将是非常感谢。
谢谢。
马克。
浏览 5提问于2020-10-13得票数 0
回答已采纳
我一直在寻找一种方法来启动和终止python中长时间运行的“批处理作业”。现在，我使用"os.system()“在每个子进程中启动一个长时间运行的批处理作业。正如您可能已经猜到的那样，"os.system()“在该子进程(孙进程？)中产生一个新进程，因此我不能终止来自祖进程的批处理作业。为了提供我刚才描述的一些可视化内容：
Main (grandparent) process, with PID = AAAA
|
|------> child process with PID = BBBB
浏览 5提问于2010-09-10得票数 5
1回答
我有用于数据处理的节点独立工作线程。根据我的服务器能力，我将运行worker的多个实例，因此我的问题是，我是否需要在worker中包含集群，因为集群的主要任务是利用多个cpu核心，但只有在我们服务于http请求时才是正确的。
但在我的例子中，如果我运行4个实例，然后每个实例都将遵循集群，所以我认为不建议对独立脚本使用集群
浏览 2提问于2015-08-25得票数 4
我目前正在尝试从anaconda中的spyder控制台运行并行化代码。我相信问题可能与我的电脑不允许anaconda控制CPU核心，但我不知道如何纠正这个问题。
另一个有趣的问题是，当我运行一个异步示例时，但是当我试图生成结果时，我会收到相同的问题。
我已经尝试了多个简单的例子，应该是有效的。没有包加载错误。
from multiprocessing.pool import ThreadPool, Pool
def square_it(x):
return x*x
# On Windows, make sure that multiprocessing doesn't st
浏览 1提问于2019-03-25得票数 1
回答已采纳
在我的项目中，我想导入命令，所以我将下面的代码放在我的项目中：
import commands
但不管怎么说我都错了：
No module named commands less... (⌘F1)
This inspection detects names that should resolve but don't. Due to dynamic dispatch and duck typing, this is possible in a limited but useful number of cases. Top-level and class-level items are
浏览 0提问于2019-04-30得票数 0
回答已采纳
为了加快函数f的速度，我编写了一段简单的代码，使用2个CPU的示例如下所示：
if __name__ == '__main__':
pool = Pool(processes = 2)
f0_list = pool.map(f,range(nlocs))
pool.terminate()
pool.join()
final_f0 = np.sum(f0_list,axis=0)
f0_final = final_f0[0:121] # here I get the error message: 'final_f0 not
浏览 3提问于2014-09-04得票数 3
回答已采纳
它们之间的区别是什么：
Script1.py
#Some python scode
#调用Scipt1：
Script2.py
import Script1
vs
Script2.py
from subprocess import call
call(["python", "Script1.py"])
浏览 1提问于2021-06-23得票数 0
2回答
我已经编写了一个脚本来检查script是否启动并运行，结果是基于返回值的。
import subprocess
url = " validurl"
def check_svn_status():
subprocess.call(['svn info'+url],shell=True)
def get_status():
subprocess.call('echo $?',shell=True)
def main():
check_svn_status()
get_status()
if __nam
浏览 4提问于2012-08-30得票数 0
回答已采纳
1回答
我试着为一年中的每一天创建一个文件，所以1月份是31，2月份是28，等等，但是因为这是一个学校作业，我也不能有一个很长的代码，所以一个聪明的方法会很好。在他们的时刻，我正在尝试这个(下面)，但它告诉我不能使用列表作为范围对象
def MonthList():
lenghtOnMonthList = [32,29,32,31,32,31,32,32,31,32,31,32]
return lenghtOnMonthList
def CreateFile(lenghtOnMonthList):
for month in range(1,13):
浏览 3提问于2014-05-02得票数 2
2回答
我正在尝试找到一种好的、简单的方法来从父进程中发信号子进程(通过使用ForkingMixIn的SocketServer创建)。
虽然可以使用Unix信号，但我希望避免使用它们，因为只有感兴趣的子进程才应该接收该信号，并且需要某种注册机制来向父进程标识感兴趣的进程，这将是一种过度和复杂的做法。
(请不要建议使用线程，因为此特定程序不能与线程一起工作，因此必须使用forks。)
浏览 0提问于2010-05-11得票数 1
回答已采纳
2回答
我在具有以下基本结构(伪代码)的服务器上运行python脚本：
for data_item in data_items:
processed_result=process_data(data_item); #this takes time T0
upload_result_to_site(processed_result) #this takes time T1
基本的制约因素是：
data_items是一个(大的)数据列表
process_data()使用了大量的cpu。
upload_result_to_site()所需的cpu非常少。
T0 = 5*T1
浏览 1提问于2019-01-23得票数 1
回答已采纳
1回答
我已经能够创建对象，这些对象是根据这个链接中的每个请求创建的：。
实际上，我正在创建一个基于的API。
我希望能够加载一个对象一次，让它返回一个经过处理的响应，而不是在每次请求时加载。该对象不是DB，只需要取消对一个大文件的筛选。
我已经翻阅了文档，但我仍然对这个整个瓶子的两个状态的事情感到困惑。
浏览 3提问于2014-06-16得票数 9
回答已采纳
我不明白为什么这个简单的代码
# file: mp.py
from multiprocessing import Process
import sys
def func(x):
print 'works ', x + 2
sys.stdout.flush()
p = Process(target= func, args= (2, ))
p.start()
p.join()
p.terminate()
print 'done'
sys.stdout.flush()
连续创建"pythonw.exe“进程，即使我从命令行运行，它也不打印任
浏览 0提问于2010-08-04得票数 15
回答已采纳
1回答
我正在尝试使用Twisted实现一个服务，它与这里的"finger“教程非常接近：
我有一个等待命令的basic.LineListener，然后执行它，然后我有一个客户端连接并发出命令。问题是这个命令有时需要执行一些其他的东西，而我使用的是python的subprocess模块。这不仅仅是对communicate()的调用挂起了，这是一个正常的子进程问题，我知道如何克服它。这是因为subprocess.Popen调用挂起了。
下面是扭曲的服务器代码：
from twisted.application import internet, service
from twisted.inter
浏览 0提问于2009-12-23得票数 3
1回答
使用多处理失败
、、
当驱动循环是常规的"for“时，此代码可以工作。当我尝试使用Pool获得加速时，它失败了。该任务是将矩阵的行按可变数量移位。它出现在射电天文学中。数组是uint8的大集合(4096,2000000)。
作品：
shiftedDataArray = np.zeros((sizeSpectrum,nSpectra), dtype= np.uint8)
dispersionDelayList = np.array([(M31delay(i, centerDM)) for i in
np.arange(sizeSpectrum) ])
@jit
def copyNumba(dispers
浏览 0提问于2016-11-21得票数 0
1回答
我目前正在重新处理一个使用python的Subprocess模块的文件。启动进程的行如下所示：
cmd = ["/usr/bin/time", '-f', '%e %M %P', '-o', time_file, script]
p = subprocess.Popen(cmd, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
在第一行中，time_file和script是一个临时存储运行时信息的文件(如已使用的ram、cpu等)。和要运行的脚本。
但是我不理解列表中的第一个参数(
浏览 0提问于2017-04-20得票数 0
当您使用Pool的multiprocessing创建进程的multiprocessing时，这些进程将分叉，父进程中的全局将显示在子进程中，在下面的问题中会注意到：
这似乎包括导入的模块。对于在__init__中有副作用的模块来说，这是一个问题。Tensorflow就是这样一个模块，一旦它被导入，它就会尝试将内存分配给GPU。这会导致子进程崩溃，因为父进程已经采取了该操作。
在分叉过程中是否有避免tensorflow模块加载的好方法？
Python 2.7 on Ubuntu (posix)
浏览 2提问于2017-04-26得票数 4
回答已采纳
我正在尝试创建基于RPA的自动化，以便在Secure CRT中运行vbscript。在这方面，我使用pyautogui模块将vbscript上传到Secure CRT。现在，我的代码甚至在从vbscript下载完所有日志之前就结束了。我如何确保我的python只有在vbscript成功运行并完成所有下载之后才会结束，以便我可以关闭secure CRT？
浏览 7提问于2018-10-04得票数 0
1回答
我是nodeJS的新手，我必须创建一个调度程序来列出在git拉中已经更改的文件。我的问题是:哪个模块/lib/way更适合这样做？
浏览 10提问于2017-11-03得票数 1
回答已采纳
我正在尝试在子进程中将写入stdout的内容显示在Qt小部件中。
我是这样开始这个过程的：
import subprocess
subprocess.call(["program_name", "arguments"])
我想我必须创建一个类来充当stdout，并在调用subprocess时指出它，我尝试了以下方法：
class Log:
def __init__(self, qtWidget):
self.qtWidget = qtWidget
def write(self, data):
self.qtWi
浏览 0提问于2013-05-27得票数 1
回答已采纳
我创建了一个instagram机器人，它使用selenium webdriver和tkinter接口。然而，当浏览器运行时，应用程序不会响应，不允许在中途关闭它或其他任何东西。tkinter应用程序在独立于实际代码的类中运行。 import tkinter as tk
from selenium import webdriver
from selenium.webdriver.common.keys import Keys
import time
import threading
import random
import sys
import mysql.connector
from mys
浏览 34提问于2019-10-04得票数 0
回答已采纳
我正在尝试为django开发的编辑器开发一个简单的。现在，它可以在编辑器中创建django项目和应用程序。这个编辑器是基于wxPython的，我想从编辑器中启动devserver，显示一个简单的表单，其中包含停止或终止/重新启动服务器的选项。
其目标是最大限度地减少在控制台/shell中执行重复任务的需要。我这么做的原因是，我在一家只有微软的公司工作，你很少使用命令行来做事情。当我进出shell/命令行来启动/重新启动服务器、syncdb、迁移等时，销售django是很困难的。为了让向我的同事销售django的工作变得更容易，并希望让开发变得更容易(至少对于喜欢在IDE中工作的django开发
浏览 6提问于2011-03-31得票数 3
回答已采纳
我想在cmd中执行一个命令，以便在-nodesktop模式下运行Matlab (所以没有gui)。我将要运行的Matlab程序将创建一个.txt文件，稍后pandas将在同一脚本中解析该文件。但在我的Windows10上(在Linux上可以工作)，pandas不会等待命令完成，而是尝试解析一个空文件，这会导致以下错误：
pandas.errors.EmptyDataError: No columns to parse from file
这是我稍后在Matlab中运行的命令(通过几个(正确的)函数调用：
matlab -nodesktop -r
然后按如下方式运行整个命令字符串：
os.sys
浏览 483提问于2020-05-23得票数 1
回答已采纳
3回答
有没有什么快速有效的方法来读取大文件的特定行，而无需将其加载到内存中？
我编写了一个perl脚本，它运行许多fork，我希望它们从文件中读取特定的行。
目前，我正在使用一个外部命令：
sub getFileLine {
my ( $filePath, $lineWanted ) = @_;
$SIG{PIPE} = '_IGNORE_';
open( my $fh, '-|:utf8', "tail -q -n +$lineWanted \"$filePath\" | head -n 1" );
m
浏览 0提问于2011-12-18得票数 8
回答已采纳
如果有人试图打开某个文件，然后它执行Linux命令，是否有任何python函数可以在该文件上创建监听程序
浏览 19提问于2020-02-07得票数 1
我目前正在从服务器端使用下面的函数来执行客户端命令。我发现当客户端同时发出多个命令并且命令执行时间较长时，这个函数会返回code=9。有没有可以解决这种问题的模块？谢谢,
def execute_cmd(cmd):
output_pipe = os.popen(cmd)
print cmd
try:
output = output_pipe.read()
print output
finally:
code = output_pipe.close()
if code is None:
浏览 1提问于2012-07-18得票数 0
在windows上使用python3.4。
我试图终止一个模拟按Ctrl+C (linux上的Ctrl+D)的人的子处理。
我只是添加了处理程序来检查信号是否被处理了。
目标是捕获KeyboardInterrupt (SIGINT)，并释放资源。但是，如果SIGINT不是来自键盘，则似乎不会抛出异常。这就是为什么我创建了一个处理程序，但是进程似乎根本不运行处理程序.
import multiprocessing
import time
import signal
import signal
import os
import sys
def handler(signal, frame):
浏览 18提问于2014-10-26得票数 5
回答已采纳
当我在Amazon 2上启动httpd (Apache)服务器时，它正在端口80和443上创建大量重复的端口侦听器。每隔几分钟就会增加另一组。最初的端口80和443以root身份启动，其他端口由apache用户启动。基本上，如果我继续运行它，它就会不断添加侦听器，直到资源完全被淹没，服务器速度减慢到爬行。运行一夜之后，端口80上有256个侦听器，端口443上有256个侦听器。(直到两天前，服务器还在正常运行-可能是在我重新启动服务器或进行基本的yum更新时启动的。但我不知道还能查些什么。)这是正常行为吗？(对于apache来说，我的经验主要是IIS)
我删除了所有附加的站点配置(自定义头)，但
浏览 0提问于2020-06-09得票数 0
回答已采纳
我有一个非常简单的金字塔应用程序，它提供一个简单的静态页面。假设它的名称是mypyramid，并使用端口9999。
如果我在另一个linux控制台中手动启动mypyramid，那么我可以使用下面的代码打印出html字符串。
if __name__ == "__main__":
import urllib2
print 'trying to download url'
response = urllib2.urlopen('http://localhost:9999/index.html')
html = resp
浏览 0提问于2015-05-11得票数 3
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
