Python多进程可迭代的更新大小
是指在多进程编程中，通过迭代器对象实现对数据的分块处理，以提高处理效率和并行性能。
在Python中，多进程编程可以通过multiprocessing模块来实现。该模块提供了Pool类，可以方便地创建进程池，并使用map方法来实现可迭代对象的并行处理。
具体而言，可以按照以下步骤来实现多进程可迭代的更新大小：
- 导入
multiprocessing模块：import multiprocessing - 创建进程池：
pool = multiprocessing.Pool(processes=num_processes)，其中num_processes为希望创建的进程数。 - 定义处理函数：创建一个函数，用于处理每个数据块的逻辑。
- 定义迭代器对象：将需要处理的数据划分为多个块，并创建一个迭代器对象，用于按块迭代数据。
- 使用
map方法进行并行处理：results = pool.map(process_function, data_iterator)，其中process_function为处理函数，data_iterator为迭代器对象。 - 处理结果：根据实际需求，对处理结果进行进一步操作或保存。
多进程可迭代的更新大小适用于需要对大量数据进行处理的场景，通过将数据划分为多个块，并利用多进程并行处理，可以提高处理速度和效率。
腾讯云提供了一系列与云计算相关的产品，如云服务器、云数据库、云存储等，可以根据具体需求选择相应的产品进行部署和使用。具体产品介绍和相关链接地址可参考腾讯云官方网站。
相关·内容
1回答
我试图在python中读取具有多处理的文件。下面是一个小例子：
import multiprocessing
from time import *
class class1():
def function(self, datasheetname):
#here i start reading my datasheet
if __name__ == '__main__':
#Test with multiprosessing
pool = multiprocessing.Pool(processes=4)
pool.map(cl
浏览 5提问于2016-12-03得票数 1
回答已采纳
我正在编写一段Python代码来使用多处理功能来解析许多ascii文件。对于每个文件，我必须执行这个函数的操作
def parse_file(file_name):
record = False
path_include = []
buffer_include = []
include_file_filters = {}
include_keylines = {}
grids_lines = []
mat_name_lines = []
pids_name_lines = []
pids_shell_lines= []
浏览 0提问于2018-08-14得票数 0
2回答
我需要在大量的fasta文件上运行一个简单的脚本。这很简单:我只需要向文件的头添加一些信息。
import os
from pathlib import Path
from Bio import SeqIO
import time
import multiprocessing as mp
def header(dirname):
with open('output.fasta', 'w') as output:
for file in os.listdir(dirname):
if file == "ou
浏览 7提问于2022-10-27得票数 0
我有一个用Python编写的数据处理任务，它使用Python CSV阅读器读取一个巨大的CSV文件，验证每一列中的数据，然后以不同的格式将每一行写入一个新文件。然后将数据大容量加载到数据库中。创建新的CSV大约需要60分钟，而负载的持续时间并不重要。
我希望加快CSV的创建，由于任务受CPU限制，最明显的解决方案是尝试并行利用服务器的所有12个核心和文件的进程部分。
我已经研究了这里可用的东西：，特别是并行Python库，它似乎正是我所需要的()，但它们似乎都不能与Python3/ Windows一起工作。
有没有人知道可以满足我的需求的并行处理框架，或者关于实现我正在尝试做的事情的最佳方法的
浏览 1提问于2012-02-29得票数 1
回答已采纳
1回答
我将把这个问题分成两部分。
我有类似于此的代码
for data in data_list:
rslt = query in databae where data == 10 # just some pseudo database query to give example but this single query usually takes around 30-50seconds.
if rslt.property == 'some condition here':
return rslt
这里的条件是
我们必须返回与查询后的条件匹配的data_lis
浏览 0提问于2019-07-28得票数 0
1回答
我有大量的模拟文件。
这些程序将在特定的软件中执行和运行。我知道我可以使用python来指导我的软件运行一个特定的文件。
我想知道我是否可以使用python强制我的计算机为每个模拟专用一个核心。
例如，假设我有10个模拟运行和3个核心。我想要那种东西
在核心1上运行Simulation1，只有在核心上运行Simulation2，只有在核心3上运行Simulation3，只有
--等模拟完成后--
..。
-模拟2完成--
只在核心2上运行Simulation4
等。
本质上，我希望python能够指示我的操作系统将特定的核心与任务关联起来。你知道有什么可能吗？
非常感谢
E
浏览 4提问于2020-02-27得票数 0
我对数据科学和滑雪板很陌生。
我有一个字符串列表如下：
[
['JAVA', 'JAVASCRIPT', 'PYTHON'],
['JAVASCRIPT', 'PYTHON', 'NODEJS'],
['JAVASCRIPT', 'JAVA'],
['JAVASCRIPT', 'PYTHON'],
['JAVA']
]
如何将上述字符串标签转换为数字标签？
我在试着获取数字标签，
其中每一个表示特定维度
浏览 1提问于2020-06-19得票数 1
回答已采纳
在Python3.7和更早版本的中，提到了padnone“模拟内置map()函数的行为”。
def padnone(iterable):
"""Returns the sequence elements and then returns None indefinitely.
Useful for emulating the behavior of the built-in map() function.
"""
return chain(iterable, repeat(None))
虽然我理解padnone的用
浏览 1提问于2019-05-02得票数 2
回答已采纳
我想实时或接近实时地从mongoDB读取数据(来自一个集合的文档)，并将其转换为pandas数据帧以供进一步分析。
我知道如何从mongoDB获取数据到python，但是，我想保持连接打开，这样每当有新数据进入时，我就可以在Python中进行实时分析。
client = MongoClient('localhost', 27017)
db = client.test_insert
collection = db.dataset
df = pd.DataFrame(list(db.dataset.find().limit(1)))
请帮助:)
浏览 2提问于2015-12-04得票数 0
我有一个函数，它要求参数同时具有大小和Iterable。
def foo(items):
print(len(items))
for i in item:
print(i)
我认为我可以从python3.5+中使用标准的python3.5+模块，并编写如下：
from typing import Collection, Any
def foo(items: Collection[Any]):
print(len(items))
for i in item:
print(i)
foo([1, 2, 3])
# PyChar
浏览 5提问于2017-06-17得票数 2
回答已采纳
我有一个设备列表，根据测试床的不同，这些设备可能会发生变化。这里我有4个节点：
node_list = [R1,R2,R3,R4]
我们是否可以编写一段python代码，以便在函数中同时使用四个值。
目前，我正在对一个测试床进行修复：
R1 = node_list[0]
R2 = node_list[1]
R3 = node_list[2]
R4 = node_list[3]
我们有一个定义来运行并发调用的pcall函数，假设我调用的函数是run_command(rtr)
pcall([run_command],iargs=[R1,R2,R3,R4])
允许所有四个节点同时调用run_comm
浏览 0提问于2016-11-05得票数 0
是否有可能在Python中用线程编程一筛子Eratosthenes，从而实现更快的输出？我见过很多用python写成的Eratosthenes的筛子，但从来没有线程。因为吉尔而不可能吗？
浏览 2提问于2019-02-28得票数 0
回答已采纳
1回答
我试图利用python的池多处理功能。
独立于我如何设置块大小(在Windows 7和Ubuntu下-后者见下面有4个内核)，并行线程的数量似乎保持不变。
from multiprocessing import Pool
from multiprocessing import cpu_count
import multiprocessing
import time
def f(x):
print("ready to sleep", x, multiprocessing.current_process())
time.sleep(20)
print(&
浏览 0提问于2018-11-14得票数 7
回答已采纳
我正在使用ffmpeg将视频转换成图像。然后，这些图像由我的Python程序处理。最初，我使用ffmpeg首先将映像保存到磁盘，然后用Python逐个读取它们。
这很好，但是为了加快程序的速度，我尝试跳过存储步骤，只处理内存中的图像。
我使用以下ffmpeg和Python子过程命令将ffmpeg的输出输送到Python：
command = "ffmpeg.exe -i ADD\\sg1-original.mp4 -r 1 -f image2pipe pipe:1"
pipe = subprocess.Popen(ffmpeg-command, stdout = subproc
浏览 0提问于2014-08-19得票数 2
回答已采纳
1回答
我正在一个6维超平面上的~350 k数据点的聚合数据集上运行一个K均值算法(使用sklearn实现)(使用6个特性)。
我也想这样做，但在我的数据集的“非聚合”版本中，它是使用相同6个特性的~1b数据点。
我知道这对K来说是一项非常繁重的任务--这意味着，数据点的数量太大了，尽管维度的大小非常小。
除了小型批处理K-方法之外，还有其他算法可以帮助我完成这个任务吗？
浏览 0提问于2021-03-23得票数 1
守则如下：
class T1():
def mytest(self,obj):
print id(obj)
if __name__=='__main__':
obj = {'a':'b'}
t1 = T1()
p1 = Process(name='p1',target=t1.mytest,args=(obj))
p1.start()
p2 = Process(name='p2',target=t1.mytest,args=(obj))
p2.
浏览 2提问于2015-11-20得票数 1
回答已采纳
我正在读取块中的csv，并将块传递给一个由4个进程组成的池。
pool = Pool(processes=4)
chunk_index = 1
for df in pd.read_csv(downloaded_file, chunksize=chunksize, compression='gzip', skipinitialspace=True, encoding='utf-8'):
output_file_name = output_path + merchant[
浏览 3提问于2017-12-16得票数 0
回答已采纳
我正在尝试学习如何使用Python的multiprocessing包，但我不明白map_async和imap之间的区别。我注意到map_async和imap都是异步执行的。那么我应该在什么时候使用一个而不是另一个呢？我应该如何检索map_async返回的结果
我应该使用这样的东西吗？
def test():
result = pool.map_async()
pool.close()
pool.join()
return result.get()
result=test()
for i in result:
print i
浏览 1提问于2014-10-23得票数 225
回答已采纳
3回答
我想知道为什么所有的std容器都没有虚拟的父级继承。
因为C++是面向对象的，所以我从算法头中得到了一些使用外部函数的理由。
但是我想知道为什么string没有size()函数(和length一样)来实现泛型？
另外，为什么没有"iterable“类可供iterables容器继承(因为迭代器的类型不同？)这一点来自我使用python的短暂经验。在我看来，python最大的优势在于使用iterable有多简单。
编辑:澄清一下:我知道C++是多范式的，但我想把重点放在容器上。我们可以使用结构和函数来保持C风格，为什么要定义一些作为方法，而另一些则不是呢？是否仅用于封装？同时拥有顺序和oo
浏览 1提问于2019-12-17得票数 1
1回答
一般情况下，我对python和编程都很陌生。这个问题是要求一个平行的阵列10辆卡车，一个阵列的英里，一个阵列的加仑，另一个成本每加仑。如果有人对有帮助的网站或视频有建议，我可以看一看，找出巨蟒，那将是很棒的！谢谢你提前帮忙。到目前为止我有这个..。
size = 10
miles[size]
gallons[size]
costs[size]
for index == 1 in size - 1:
print("Enter the miles, gallons, and costs of fuel for truck 1.", index + 1)
miles[ind
浏览 1提问于2015-04-19得票数 0
回答已采纳
@ Padraic Cunningham如果你想让我删除这个问题，请告诉我。
我对蟒蛇很陌生。我想跳过一些基于某些条件的迭代器值。这在C语言中很容易，但在python中，我遇到了困难。
因此，请帮助我理解为什么这里的代码循环100次而不是10次。
for i in range(100):
print i
i = i +10
编辑：我知道有选项可以更改for循环的步骤大小。但是我对动态地改变迭代器变量很感兴趣，就像我们可以在C中做的一样。好的，我明白，因为循环在python中和C中是不同的。简单的方法是使用while循环，我在我的代码中这样做了，它起作用了。谢谢大家！
浏览 28提问于2016-04-15得票数 5
回答已采纳
1回答
矩阵中行的相交
、、、
我在python中有以下列表：
a = [1, 2, 3, 4 ,5]
b = [[1, 2, 3], [2, 3, 4, 5], [3, 4, 5]]
我想把a与b的每一行交叉起来。
d = set(a).intersection(set(b[0]), set(b[1]), set(b[2]))
可以工作，但是我需要迭代方法，因为如果b中的行数增加，那么像这样写所有的行就太过了。另外，如果我在a中取了许多行，那么与a和b相交的相应行也需要迭代。我们该怎么办。
我检查过交叉口，但通常它们只给出2、3或4组的交集。交叉路口呢，比如128组。
浏览 2提问于2022-04-12得票数 0
Traceback (most recent call last): File "tb_list_spider.py", line 42, in parse_tblist
driver = webdriver.PhantomJS(desired_capabilities=desired_capabilities) File "/usr/local/lib/python3.6/site-packages/selenium/webdriver/phantomjs/webdriver.py", line 52, in __init__
self
浏览 3提问于2017-11-30得票数 0
用于python 2.7.13
>>> lst_ = [1]
>>> map(lambda x, y: x + y if y else 1, lst_, lst_[1:])
[1]
用于python 3.6.1
>>> lst_ = [1]
>>> list(map(lambda x, y: x + y if y else 1, lst_, lst_[1:]))
[]
两个问题：
我想知道为什么python2返回正确的结果，但python3不返回任何结果。
如何用python3修改代码以返回正确的结果
浏览 0提问于2017-06-13得票数 2
回答已采纳
1回答
我有一个程序使用多处理库来计算一些东西。大约有10K的输入要计算，每个输入在0.2秒到10秒之间。
我目前的方法是使用一个池：
# Inputs
signals = [list(s) for s in itertools.combinations_with_replacement(possible_inputs, 3)]
# Compute
with mp.Pool(processes = N) as p:
p.starmap(compute_solutions, [(s, t0, tf, folder) for s in signals])
print ("
浏览 1提问于2018-05-16得票数 3
回答已采纳
1回答
平行速度
、、
我正在尝试处理python的并行性。这是我正在使用的代码
import time
from concurrent.futures import ProcessPoolExecutor
def listmaker():
for i in xrange(10000000):
pass
#Without duo core
start = time.time()
listmaker()
end = time.time()
nocore = "Total time, no core, %.3f" % (end- start)
#with duo core
浏览 4提问于2015-03-21得票数 1
回答已采纳
1回答
我写了一些代码，以获得传感器读数从GPIO的时间。为了确保测量值对应于特定的时间，我想知道python是否以恒定的速度迭代(因此迭代之间的间隔是恒定的)，以及迭代之间的最小时间间隔是多少。
如果他们不是，谁能让我知道如何使时间间隔不变。谢谢!
浏览 2提问于2015-04-01得票数 3
回答已采纳
在Joel的“”第2章中，提供了以下例子：
all([ ]) # True, no falsy elements in the list
any([ ]) # False, no truthy elements in the list
根据Grus的说法，Python将[] (一个空列表)视为一个"falsey“参数。那么，为什么我们会根据all()或any()参数应用于空列表而得到不同的结果呢？
浏览 7提问于2017-03-09得票数 1
回答已采纳
1回答
我想要创建一个三维动画散点图，其中最新的点显示在一定的颜色，然后灰色，直到下一个点被生成。
输入文件'coordinates.txt‘只包含三列中的x、y和z值。
只要我跳过z值，只使用2d投影，代码就能工作。当我添加z坐标时，我得到一个TypeError: object of type 'float' has no len()。
我不明白为什么我得到了这个3d错误，而不是2d投影，以及为什么它要在3d版本中计算len()。
如果有人能帮我解决这个问题，我会很高兴的！
input_file = open('coordinates.txt', 'r
浏览 5提问于2015-07-14得票数 2
回答已采纳
在查看其他人在LeetCode上的解决方案时，我偶然发现了一些代码：
def findLeaves(self, root):
if not root: return []
kids = map(self.findLeaves, (root.left, root.right))
return map(lambda l, r: (l or []) + (r or []), *kids) + [[root.val]]
我发现它只适用于Python 2，而不适用于3，因此我做了以下调试：
Python 2：
a = [[],[]]
b = map(lambda l, r: (l
浏览 0提问于2018-09-03得票数 0
回答已采纳
关于以下代码片段的功能，我有几个问题。
def f(x):
return x*x
if __name__ == '__main__':
pool = Pool(processes=10) # start 10 worker processes
result = pool.apply_async(f, [10]) # evaluate "f(10)" asynchronously
print result.get(timeout=1)
print pool.map(f,
浏览 3提问于2013-10-30得票数 0
1回答
a=['1','2','3']
使用list可以耗尽map(int,a)以获得输出：
list(map(int,a))
输出：1,2,3
a=['1','2','3']
b=['1','2']
我如何用尽以下几点：
map(int,a,b)
浏览 0提问于2014-03-14得票数 2
回答已采纳
在使用multiprocessing和range()生成器时，我遇到了一些奇怪的行为，我不知道发生了什么。
以下是代码：
from multiprocessing import Pool
import time
def worker_thread(param):
time.sleep(1)
print(param, end=' ', flush=True)
p = Pool(1)
inp = list(range(0, 100))
p.map(worker_thread, inp)
当执行此代码(只有一个线程)时，输出将如预期的那样：
0 1 2 3 4
浏览 2提问于2015-04-24得票数 0
回答已采纳
我使用*或**将参数传递给Python2中的函数，而不是问题，通常使用list、set和dictionary。
def func(a, b, c):
pass
l = ['a', 'b', 'c']
func(*l)
d = {'a': 'a', 'b': 'b', 'c': 'c'}
func(**d)
然而，在Python3中，出现了用dict_keys、dict_values、range、map等替代list的新对象。
虽然我已经将Py
浏览 2提问于2017-12-21得票数 0
回答已采纳
在python中实现多处理的一种简单方法是
from multiprocessing import Pool
def calculate(number):
return number
if __name__ == '__main__':
pool = Pool()
result = pool.map(calculate, range(4))
一个基于期货的替代实现是
from concurrent.futures import ProcessPoolExecutor
def calculate(number):
return number
浏览 3提问于2014-07-22得票数 23
回答已采纳
我刚开始使用python map()函数来实现并行代码。
def main_function(sample):
# ......(only input file; calculations; and output file)
if __name__ == "__main__":
list_sample_common = os.listdir('/lustre/scratch/Stat/s1155136154/ONT_Panel2')# WES,ONT_panel, Pacibo_Panel intersection.
list_samp
浏览 0提问于2021-02-22得票数 0
回答已采纳
试图将此选民类添加到自定义用户模型中。我不认为我需要像我那样创建一个自定义模型，但我已经对它感兴趣了，我不想从头开始。基本上，我正在尝试创建一个匹配系统，在这个系统中，两个用户可以彼此选择“是”或“否”，然后进行匹配。不管怎么说，迁徙成功了。但是，当我将它添加到admin.py时，我得到
误差
Watching for file changes with StatReloader
Performing system checks...
Exception in thread django-main-thread:
Traceback (most recent call last):
Fi
浏览 4提问于2020-03-28得票数 0
对于python/php应用程序，我使用韦伯派共享托管服务。有一件事我不明白。
每次我安装一个新的PHP应用程序时，都不会创建新的进程。但是安装一个新的Python应用程序会在服务器上创建至少3个新的进程。
为什么每个Python应用程序都需要几个进程，而PHP应用程序却不需要？
编辑: python应用程序在Apache上与WSGI一起运行。
浏览 0提问于2010-10-04得票数 0
1回答
我遇到了一个问题，我需要创建一个列表的所有可能的变体字符串。我已经尝试过一些迭代工具的方法，比如[''.join(i) for i in itertools.permutations('abc')]或
(comb = [''.join(i) for i in itertools.combinations_with_replacement('abc',3)]，但他们有一点不同的结果，正如我所期望的。我需要所有的变体，所以置换不是实现它的方法。替换的组合很好，但是缺少了一些子序列，这个操作的结果是：
aab
aac
abb
abc
a
浏览 1提问于2020-11-27得票数 1
回答已采纳
我有一个设置，我通过multiprocessing.queue发送一个字典，并用它做一些事情。当我没有改变字典中的任何东西时，我得到了一个奇怪的“字典大小在迭代时改变了”的错误。下面是回溯，尽管它不是很有帮助：
Traceback (most recent call last):
File "/usr/lib/python2.6/multiprocessing/queues.py", line 242, in _feed
send(obj)
RuntimeError: dictionary changed size during iteration
因此，我尝试将字
浏览 0提问于2010-04-16得票数 4
1回答
我试着用python2.7和scikit做一个简单的垃圾邮件过滤器--学习。所以，我有一组用于火车的字母和一组测试的字母。首先对训练集进行向量化和拟合logistic回归，然后对测试集中的每个字母进行矢量化，并将它们分别放入分类器。
import codecs
import json
import os
from sklearn.feature_extraction.text import CountVectorizer
from sklearn import linear_model
def classify(mail, vectorizer, logreg):
vect_mail
浏览 0提问于2015-01-08得票数 1
回答已采纳
3回答
用例如下:我有一个运行一系列非python可执行文件以减少(pulsar)数据的脚本。我现在使用subprocess.Popen(...，shell=True)，然后使用子进程的通信函数来捕获来自非python可执行文件的标准输出和标准错误，以及使用python日志记录模块记录的捕获输出。
问题是:在可能的8个核心中，只有一个核心现在大部分时间都在使用。我希望产生多个进程，每个进程并行处理数据集的一部分，并且希望跟踪进度。它是一个脚本/程序，用于分析来自低频射电望远镜(LOFAR)的数据。安装/管理和测试越容易越好。我正要构建代码来管理这一切，但我确信它一定已经以某种简单的库形式存在了。
浏览 0提问于2010-11-03得票数 2
回答已采纳
我第一次在Python中尝试多线程。我看到了。下面是我的示例代码
from multiprocessing.dummy import Pool as ThreadPool
pool = ThreadPool(4)
mylist = [3,4,5,6,7,8, ..., 5]
results = pool.map(my_method, my_list) # from docs it is clear that pool.map takes method and argument as a list
def my_method(mylist):
data = []
for i
浏览 1提问于2017-05-29得票数 1
回答已采纳
我正在阅读Python，在下，我找到了以下__init__定义(缩写)：
class ListBasedSet(collections.abc.Set):
''' Alternate set implementation favoring space over speed
and not requiring the set elements to be hashable. '''
def __init__(self, iterable):
self.elements = lst = []
浏览 4提问于2016-09-14得票数 0
回答已采纳
1回答
我在Python3.8中有以下数据处理管道：
存储在SSD上的原始数据约1.3TB，细分为大约80个不同的独立类别，进一步细分为单独的300 of压缩csv.gz3主类，一个将原始数据清理成可读格式，另一个将所述数据进行汇总并进行我所需的数学运算，第三个导入前2个，读取每个csv，运行所有这些进程并保存结果，遍历csv。我有约束，因为它是时间序列数据，所以我必须按顺序执行，因为所有这些都取决于每个类别以前的值(没有向量化)。我已经尽可能使用Cython和Numba了。
我的电脑有12个核心/24个线程。理想情况下，我希望程序的24个实例同时运行，每个线程一个实例，每个实例尽可能快地从一个类别导
浏览 3提问于2021-04-20得票数 0
我有一个Python应用程序，因为有一个第三方库，所以我必须使用Python2.7，但我正在努力充分利用它。
我已经下载了PyLint 1.9.5，现在基本上可以正常工作了。有一件事我正在跌跌撞撞地找不到解决的办法。
我有一些类，基本上是这样的：
class Narg(object):
[snip]
class Foo(object):
def __init__(self):
self.bar = None # type: Optional[list[Narg]]
def find(self):
if self.bar:
fo
浏览 7提问于2021-11-28得票数 3
1回答
我试图为Python和C/C++进程的任何组合之间的进程间通信建立一个快速库。(i.e. Python <-> Python, Python <-> C++, or C++ <-> Python)
为了实现最快的实现，我尝试使用mmap来利用共享内存。该计划是让两个进程通过"mmap-ing“共享内存，并从这个共享内存中读取并写入以进行通信。
我希望避免对实际文件的任何实际写入，而只是希望使用文件名作为两个进程连接的句柄。但是，在下面调用mmap时，我被挂断了
self.memory = mmap.mmap(fileno, self.maxlen)
浏览 12提问于2021-02-12得票数 3
回答已采纳
1回答
我刚接触Python，但我对Python中的迭代器和迭代器的理解是它们支持迭代器协议。 在一些迭代工具/上下文中，迭代器被传递给iter()以返回迭代器。然后，连续调用next()以生成所有项，直到next()引发StopIteration异常。 迭代器只支持一次迭代，而不是自己的迭代器的迭代器将支持多次迭代。 似乎取消了迭代器和迭代器之间的区别，让所有的迭代器都有自己的多遍迭代器，这样会更干净。 在迭代器协议中分离迭代器和迭代器的好处/逻辑是什么？
浏览 24提问于2020-04-29得票数 0
我不能为这个问题做一个可重复的例子；请仔细检查我的逻辑是否存在误解，或者我是否遗漏了什么。
我正在尝试写一个脚本来检查python应用程序，如果它已经停止工作，给我发一封电子邮件。我正在使用psutil检查正在运行的进程。下面是我的函数，它检查有问题的程序是否正在运行(我定期调用这个函数)。
def programRunning():
cmdLines = []
for pid in psutil.pids():
p = psutil.Process(pid)
if p.name() == "pythonw.exe
浏览 1提问于2018-01-19得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
