在1个脚本中运行2个永久运行的函数
在一个脚本中运行两个永久运行的函数可以通过多线程或多进程来实现。
多线程是指在一个进程内创建多个线程，每个线程执行不同的函数。多线程可以共享进程的资源，但需要注意线程安全的问题。在Python中，可以使用threading模块来实现多线程。
多进程是指在操作系统中创建多个独立的进程，每个进程执行不同的函数。多进程之间相互独立，各自拥有独立的资源。在Python中，可以使用multiprocessing模块来实现多进程。
以下是使用多线程和多进程实现在一个脚本中运行两个永久运行的函数的示例代码：
- 多线程实现：
import threading
def function1():
while True:
# 第一个永久运行的函数的逻辑
pass
def function2():
while True:
# 第二个永久运行的函数的逻辑
pass
if __name__ == "__main__":
thread1 = threading.Thread(target=function1)
thread2 = threading.Thread(target=function2)
thread1.start()
thread2.start()在上述代码中，我们使用threading.Thread创建了两个线程，分别执行function1和function2函数。通过调用start方法启动线程。
- 多进程实现：
import multiprocessing
def function1():
while True:
# 第一个永久运行的函数的逻辑
pass
def function2():
while True:
# 第二个永久运行的函数的逻辑
pass
if __name__ == "__main__":
process1 = multiprocessing.Process(target=function1)
process2 = multiprocessing.Process(target=function2)
process1.start()
process2.start()在上述代码中，我们使用multiprocessing.Process创建了两个进程，分别执行function1和function2函数。通过调用start方法启动进程。
需要注意的是，多线程和多进程都可以实现在一个脚本中运行两个永久运行的函数，但具体使用哪种方式取决于实际需求和场景。在选择使用多线程或多进程时，需要考虑到线程安全、资源共享、性能等因素。
相关·内容
1回答
Python -在流程子类中创建线程子类的问题&线程和多处理
python、multithreading、multiprocessing
我很难让线程(threading.Thread)子类在进程(multiprocessing.Process)子类中工作。
下面是演示这个问题的最简单的工作示例。我创建了一个"SubProcess“(multiprocessing.Process的实例)，它将包含一个子"WorkerThread”(threading.Thread实例)。执行在subProcess.start()终止
import multiprocessing
import threading
class SubProcess(multiprocessing.Process):
def __init_
浏览 1提问于2021-10-21得票数 0
回答已采纳
1回答
multiprocessing.Process不会同时打开多个驱动程序并抓取它们
python、selenium、web-scraping、webdriver、multiprocessing
我尝试在Python语言中使用selenium打开多个网页，并使用不同的帐户同时与这些网页进行交互，但它只在完成a1之后才启动a2。为什么它不同时运行这两个功能，这样我就可以同时使用多个帐户与网站交互？
def function1(url,email,password):
driver = webdriver.Chrome
driver.get(website url)
# LOG IN
def function2(url,email,password):
driver = webdriver.Chrome
driver.get(website url)
# LOG IN US
浏览 3提问于2018-08-28得票数 0
回答已采纳
1回答
如何与多处理中的另一个脚本共享全局变量？
python、multiprocessing、python-multiprocessing
问:如何在script2中使用变量x？我有两个脚本，其中第一个包含两个多处理功能，第二个包含一个多处理功能。如何对所有3个多处理函数使用共享变量？
script1.py
from script2 import function3
x = None
def function1():
global x
while True:
x = input() # updates global variable x
def function2():
global x
while True:
print(x) # prints glob
浏览 2提问于2021-07-07得票数 0
回答已采纳
1回答
Python线程不能同时运行2个进程
multithreading、python-3.7
我已经尝试过使用multiprocessing.Process(target=hello()).start()和threading.Thread(target=hello())、.start()来做这件事，但是都没有成功。
import threading
def hello():
while True:
print("hello")
def world():
while True:
print("world")
threading.Thread(target=hello()).start()
threa
浏览 0提问于2019-06-20得票数 0
2回答
Python线程和多处理错误？
python、linux、multithreading、multiprocessing
threading.Timer和multiprocessing.Process是不是产生了另一个独立于其他进程的进程？示例我的代码如下，假设它执行了一轮if语句，这使它执行multiprocessing.Process和threading.Timer，现在是20秒，所以它仍然等待40秒才能完成代码，但是如果它再次执行if语句，它会得到任何错误或其他什么吗？
def myFunction3():
#some stuffs
def myFunction2(a,b):
time.sleep(60)
subprocess.Popen([.....],....) #with a
浏览 7提问于2012-08-04得票数 1
3回答
Python的多进程不能很好地与threading.local配合使用？
python、multithreading、multiprocessing、python-multithreading
我有两个进程(参见示例代码)，每个进程都试图访问一个threading.local对象。我希望下面的代码打印"a“和"b”(按任意顺序)。相反，我得到了"a“和"a”。当我启动整个新进程时，怎样才能优雅而可靠地重置threading.local对象？
import threading
import multiprocessing
l = threading.local()
l.x = 'a'
def f():
print getattr(l, 'x', 'b')
multiprocessing.Proces
浏览 0提问于2011-09-02得票数 12
回答已采纳
1回答
Python: MultiProcess函数中的线程运行在与多进程函数或父进程函数相同的核心中？
python、python-multiprocessing、python-multithreading
def multiprocess_function():
run = 0
while run == 0:
for i in the range(100):
#This will initiate 100 threads
threading.Thread(target=sum, args=(i,0))
time.sleep(10)
p1 = multiprocessing.Process(target=multiprocess_function)
p1.start
在上面的代码片段中，我开始了一个新的无限循环进程(在一个
浏览 1提问于2020-08-06得票数 0
回答已采纳
1回答
AttributeError 'DupFd‘in 'multiprocessing.resource_sharer’| Python多处理+线程
python、multithreading、concurrency、multiprocessing、python-multiprocessing
我试图在多个执行I/O限制任务的threading.Thread和多个执行CPU限制任务的multiprocessing.Process之间进行通信。当线程为进程找到工作时，它将与multiprocessing.Pipe(duplex=False)的发送端一起放在multiprocessing.Queue上。然后，这些进程完成各自的工作，并通过管道将结果发送回线程。这个过程似乎在大约70%的情况下有效，另外30%我收到了AttributeError: Can't get attribute 'DupFd' on <module 'multiprocessi
浏览 32提问于2018-09-10得票数 1
回答已采纳
4回答
业绩差异
python、performance、multiprocessing、python-multithreading
有谁能解释为什么代码1比CODE2好，反之亦然：
一些数据:具有4核的计算机，并且需要执行8独立的任务()，每个taks需要大量的处理、循环、计算等：
代码1:进程+线程
results = multiprocessing.Queue()
p1 = multiprocessing.Process(target=bigTask1, args=(some_arguments, results))
p2 = multiprocessing.Process(target=bigTask2, args=(some_arguments, results))
p3 = multiprocessing.P
浏览 4提问于2014-07-21得票数 0
回答已采纳
1回答
multiprocessinq.Queue作为Queue.Queue子属性
python、multithreading、queue、multiprocessing
我试图弄清楚下面的模块在做什么。
import Queue
import multiprocessing
import threading
class BufferedReadQueue(Queue.Queue):
def __init__(self, lim=None):
self.raw = multiprocessing.Queue(lim)
self.__listener = threading.Thread(target=self.listen)
self.__listener.setDaemon(True)
浏览 0提问于2014-10-02得票数 1
回答已采纳
2回答
Python多处理与多线程相结合
python、multithreading、multiprocessing
我不确定我试图做的是不是一个有效的实践，但它是这样的:我需要我的程序高度并行化，所以我想我可以创建2-3个进程，每个进程可以有2-3个线程。
1)这是可能的吗? 2)它有什么意义吗? 3)这是我的代码，但当我试图加入进程时它挂起了。
PQ = multiprocessing.Queue()
..。
def node(self, files, PQ):
l1, l2 = self.splitList(files)
p1 = multiprocessing.Process(target=self.filePro, args=(l1,PQ,))
p2
浏览 5提问于2014-12-13得票数 14
回答已采纳
1回答
Python多处理不工作
python、multithreading、multiprocessing
我看过你可以用同样的方式使用多线程和多线程。我尝试过用多线程来完成这个任务，但是它不能处理多进程。
我正在运行以下代码：
import multiprocessing
import time
test_list = []
def user_input():
while True:
number = raw_input('Please input a number: ')
test_list.append(number)
def print_func():
while True:
for t in tes
浏览 3提问于2014-07-25得票数 0
回答已采纳
1回答
有些线程永远不会自己退出
python、multithreading
这是我昨天上传的一个类似的源码，但多亏了你的帮助才解决了一些问题。
问另一个同样的问题有点丢脸：
但是，尽管我一整天都在考虑问题是什么，我还是没有找到。所以,
它看起来不错，确实可以工作，但问题是，有些线程在很长一段时间内都不会自行终止。
我甚至等待了10分钟，但仍有6个线程仍在运行。
这是我开始学习编程以来最神秘的事情。
你能告诉我它有什么问题吗？
import os
import threading
import multiprocessing
def finder(path, q, done):
for root, dirs, files in os.walk(uni
浏览 0提问于2012-07-10得票数 0
回答已采纳
1回答
Python Kafka多进程vs线程
python、apache-kafka、python-multiprocessing、python-multithreading
我可以使用KafkaConsumer在单独的线程中使用消息。
但是，当我使用multiprocessing.Process而不是threading.Thread时，我会得到一个错误：
OSError: [Errno 9] Bad file descriptor
这个和建议使用多处理并行地使用消息是可能的。有谁能给我举个例子吗？
编辑
这是一些示例代码。不好意思，原来的代码太复杂了，所以我在这里创建了一个示例，希望能够告诉您正在发生的事情。如果我使用threading.Thread而不是multiprocessing.Process，这段代码可以正常工作。
from multiprocessin
浏览 3提问于2017-09-29得票数 4
回答已采纳
1回答
如果一个函数在一个线程中运行，并且如果它调用了另一个函数，那么在smae线程中运行它？
python、python-3.x、multithreading、python-multithreading
在我的脚本中有两个"main“函数。它们中的每一个都在调用其他函数。这两个主要函数在两个不同的踏步上运行。这些函数是也在这些线程中调用还是在主线程中运行？示例：
def main():
//something
function1()
def main2():
//something
function2()
t1=threading.Thread(target=main)
t2=threading.Thread(target=main2)
t1.start()
t2.start()
提前感谢
浏览 0提问于2020-06-10得票数 0
1回答
python多进程中的共享变量不起作用
python
我想在学校的项目中使用多进程，但我在多个进程之间共享变量时遇到了问题。为了模拟这个问题，我编写了一些代码来向您展示：
import multiprocessing
import ctypes
import time
def function1():
global value
while True:
value.value += 1
time.sleep(1)
def function2():
global value
while True:
value.value += 1
time.s
浏览 0提问于2021-01-14得票数 1
1回答
OpenCV中的Python线程问题
python、python-3.x、opencv、python-multiprocessing、python-multithreading
我在OpenCV中使用threading模块时，遇到了一个奇怪的问题。当使用线程时，我无法再次启动摄像头来获取视频输入。我会拍一帧然后停下来。而在使用multiprocessing模块时却没有这样的问题。我不能理解是什么导致了这种奇怪的行为。 这段代码总结了我遇到的问题，当第二次创建线程时，程序会卡住。 import cv2
import time
import threading
def open_cam():
count = 0
cam = cv2.VideoCapture(0)
while True:
ret_val, img = cam.re
浏览 13提问于2019-06-18得票数 1
1回答
Python并发性能
python、multithreading、performance、concurrency、parallel-processing
我第一次在Python中面对并发性，目标是优化我的脚本。基本上，我有一个脚本，它对一些文件使用os.system调用第三方jar工具。在使用线程(threading.Thread和threading.Queue) 127之后，我的第一个“过程”版本花了大约135秒完成，现在切换到多进程(multiprocessing.Process和multiprocessing.JoinableQueue) 113秒.但还是有很多时间..。你能给我一些反馈和/或指出一篇可能解决我的问题的文章吗？
(我使用的是Python2.7.1，我想避免使用3d派对模块)
浏览 1提问于2012-10-23得票数 0
1回答
在同时运行的两个函数中访问同一个对象的属性
python、object、multiprocessing、visibility
你好，我遇到了一个奇怪的问题，也许有人能帮上忙，我首先用相同的参数运行两个不同的函数，这个参数是一个已经实例化的对象：
iotComponent.connectedSensors=sensorList
iotComponent.connectedHUIs=HUIList
Coap = multiprocessing.Process(target=runCoapSync,args=(iotComponent,))
huis = multiprocessing.Process(target=runHuis,args=(iotComponent,))
huis.start()
Coap.start
浏览 0提问于2018-09-27得票数 2
回答已采纳
3回答
Python中具有多线程的多进程
python、multithreading、multiprocessing、gil
我听说过“如果你想从并行应用程序中获得最大的性能，你应该创建和你的计算机的CPU一样多的进程，并且在每个进程中--创建一些(多少？)线程”。
是真的吗？
我写了一段代码来实现这个习惯用法：
import multiprocessing, threading
number_of_processes = multiprocessing.cpu_count()
number_of_threads_in_process = 25 # some constant
def one_thread():
# very heavyweight function with lots of CPU
浏览 6提问于2014-07-30得票数 4
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频活动推荐
腾讯云开发者
