我只要两个子进程，修改错误""" 创建进程的步骤 1.导入模块multiprocessing 2.创建process的对象 3.调用stratU()启动进程 """ from multiprocessing import Process import time def outputNumbers(): for i in range(100): print(i) time.sleep(0.5) def showTime(): # timetuple=(2023,5,27,1,1,1,1,1) while True: print(time.strftime("%Y-%m-%d,%i:%m:%S",time.localtime())) time.sleep(0.5) def dance(): while True: print("dongc ci da ci") time.sleep(1) if __name__=="__main__": p1=Process(target=outputNumbers,daemon=True) # 设置进程为守护进程，结束时主进程结束子进程结束 p2=Process(target=showTime,daemon=True) p1.start() p2.start() dance() print("主进程结束")

如果你只需要两个子进程，可以将 `dance()` 函数移除，修改后的代码如下：

from multiprocessing import Process
import time

def outputNumbers():
    for i in range(100):
        print(i)
        time.sleep(0.5)

def showTime():
    while True:
        print(time.strftime("%Y-%m-%d,%i:%m:%S",time.localtime()))
        time.sleep(0.5)

if __name__=="__main__":
    p1 = Process(target=outputNumbers, daemon=True)
    p2 = Process(target=showTime, daemon=True)
    p1.start()
    p2.start()
    while True:
        time.sleep(1)
        if not (p1.is_alive() and p2.is_alive()):
            break
    print("主进程结束")

在主进程中创建了两个子进程，并在之后增加了一个死循环，用于检测两个子进程是否都已经结束，如果两个子进程都结束了，则跳出循环，主进程也结束。

相关问题

改进""" 创建进程的步骤 1.导入模块multiprocessing 2.创建process的对象 3.调用stratU()启动进程 """ from multiprocessing import Process import time def outputNumbers(): for i in range(100): print(i) time.sleep(0.5) def showTime(): # timetuple=(2023,5,27,1,1,1,1,1) while True: print(time.strftime("%Y-%m-%d,%i:%m:%S",time.localtime())) time.sleep(0.5) def dance(): while True: print("dongc ci da ci") time.sleep(1) if __name__=="__main__": p1=Process(target=outputNumbers,daemon=True) # 设置进程为守护进程，结束时主进程结束子进程结束 p2=Process(target=showTime,daemon=True) p1.start() p2.start() dance() print("主进程结束")

你的代码中只创建了两个子进程，如果需要同时运行三个函数，可以将第三个函数也创建为一个子进程，修改后的代码如下：

from multiprocessing import Process
import time

def outputNumbers():
    for i in range(100):
        print(i)
        time.sleep(0.5)

def showTime():
    while True:
        print(time.strftime("%Y-%m-%d,%i:%m:%S",time.localtime()))
        time.sleep(0.5)

def dance():
    while True:
        print("dongc ci da ci")
        time.sleep(1)

if __name__=="__main__":
    p1 = Process(target=outputNumbers, daemon=True)
    p2 = Process(target=showTime, daemon=True)
    p3 = Process(target=dance, daemon=True)
    p1.start()
    p2.start()
    p3.start()
    while True:
        time.sleep(1)
        if not (p1.is_alive() and p2.is_alive() and p3.is_alive()):
            break
    print("主进程结束")

在主进程中创建了三个子进程，并在之后增加了一个死循环，用于检测三个子进程是否都已经结束，如果三个子进程都结束了，则跳出循环，主进程也结束。

python进程池multiprocessing.Pool和线程池multiprocessing.dummy.Pool实例

Python的multiprocessing.Pool模块和multiprocessing.dummy.Pool模块都是用于创建进程池和线程池的工具。

进程池(multiprocessing.Pool)是一组维护在进程中的工作者，它们可以并行地执行任务。该模块是基于multiprocessing模块实现的，它通过创建多个进程来并行执行任务。

下面是一个创建进程池的示例：

import multiprocessing

def worker(process_num):
    print("Process %d is working" % process_num)

if __name__ == '__main__':
    pool = multiprocessing.Pool(processes=4)
    for i in range(5):
        pool.apply_async(worker, args=(i,))
    pool.close()
    pool.join()

上面的示例中，我们创建了一个包含4个进程的进程池，并向进程池中提交了5个任务，每个任务调用worker函数并传递一个进程编号作为参数。我们使用apply_async方法向进程池中提交任务，并使用close和join方法管理进程池。

线程池(multiprocessing.dummy.Pool)是一组维护在线程中的工作者，它们可以并行地执行任务。该模块是基于threading模块实现的，它通过创建多个线程来并行执行任务。

下面是一个创建线程池的示例：

from multiprocessing.dummy import Pool
import time

def worker(thread_num):
    print("Thread %d is working" % thread_num)
    time.sleep(1)

if __name__ == '__main__':
    pool = Pool(4)
    for i in range(5):
        pool.apply_async(worker, args=(i,))
    pool.close()
    pool.join()

上面的示例中，我们创建了一个包含4个线程的线程池，并向线程池中提交了5个任务，每个任务调用worker函数并传递一个线程编号作为参数。我们使用apply_async方法向线程池中提交任务，并使用close和join方法管理线程池。

需要注意的是，线程池和进程池的用法基本相同，但是由于线程在Python中不能真正地并行执行，因此线程池的性能可能比进程池差。