[已解决]修改代码 并行与并发

a聪明叶

可以帮忙修改下代码吗？使代码可以成功跑起

import time
from threading import Thread
from multiprocessing import Process


def is_prime(n):
    """ 判断n是否为素数 """
    if n == 1:
        return False
    else:
        assert isinstance(n, int)
        num = int(n ** 0.5)
        for i in range(2, num + 1):
            if n % i == 0:
                return False
        return True


def sum_primes(n):
    """ 计算小于等于n的素数之和 """
    sump = 0
    i = 0
    for i in range(0, n + 1):
        if is_prime(i) == True:
            sump = sump + i
        i = i + 1
    print(sump, end=" ")
    return sump


def io(n):
    """ 模拟IO密集型 """
    time.sleep(1)
    print(n, end=" ")
    return n


def debug(func):
    """ 装饰器，记录运行时间
    提示：在函数执行前执行start_time = time.time()获取开始时间
         在函数执行后执行end_time = time.time()获取完成时间
    """

    def int_time(*args, **kwargs):
        start_time = time.time()  # 程序开始时间
        func()
        end_time = time.time()  # 程序结束时间
        total_time = end_time - start_time
        print('程序共计%s秒' % total_time)

    return int_time


@debug
def for_work(func, numbers):
    """ 顺序执行工作 """
    for n in numbers:
        func(n)


@debug
def thread_work(func, numbers):
    """ 并发 """
    th = []
    for n in numbers:
        t = Thread(target=func)
        th.append(t)
    for n in numbers:
        t.start()
    for n in numbers:
        t.join()


@debug
def process_work(func, numbers):
    """ 并行 """
    th = []
    for n in numbers:
        t = Process(target=func)
        th.append(t)
    for n in numbers:
        t.start()
    for n in numbers:
        t.join()


def main():
    numbers = (100000, 200000, 300000, 400000, 500000, 600000, 700000, 800000)
    # CPU密集型
    for_work(sum_primes, numbers)
    thread_work(sum_primes, numbers)
    process_work(sum_primes, numbers)

    # IO密集型
    for_work(io, numbers)
    thread_work(io, numbers)
    process_work(io, numbers)


if __name__ == "__main__":
    main()

最佳答案

月排行榜 / 总排行榜

Twilight6

2020-6-10 15:02:12

第一个报错是因为你参数少了两，我也不懂传入的对不对，对修饰符和线程了解很少，所以代码几乎看不懂：

1. func()  # <--这边要两个参数才能运行

复制代码

瞎改成：

1. func(*args,**kwargs)

复制代码

完整代码：

1. import time
   
2. from threading import Thread
   
3. from multiprocessing import Process
   
4. 
   
5. 
   
6. def is_prime(n):
   
7.     """ 判断n是否为素数 """
   
8.     if n == 1:
   
9.         return False
   
10.     else:
    
11.         assert isinstance(n, int)
    
12.         num = int(n ** 0.5)
    
13.         for i in range(2, num + 1):
    
14.             if n % i == 0:
    
15.                 return False
    
16.         return True
    
17. 
    
18. 
    
19. def sum_primes(n):
    
20.     """ 计算小于等于n的素数之和 """
    
21.     sump = 0
    
22. 
    
23.     for i in range(n + 1):
    
24.         if is_prime(i) == True:
    
25.             sump = sump + i
    
26. 
    
27.     print(sump, end=" ")
    
28.     return sump
    
29. 
    
30. 
    
31. def io(n):
    
32.     """ 模拟IO密集型 """
    
33.     time.sleep(1)
    
34.     print(n, end=" ")
    
35.     return n
    
36. 
    
37. 
    
38. def debug(func):
    
39.     """ 装饰器，记录运行时间
    
40.     提示：在函数执行前执行start_time = time.time()获取开始时间
    
41.          在函数执行后执行end_time = time.time()获取完成时间
    
42.     """
    
43.     def int_time(*args, **kwargs):
    
44.         start_time = time.time()  # 程序开始时间
    
45.         func(*args,**kwargs)
    
46.         end_time = time.time()  # 程序结束时间
    
47.         total_time = end_time - start_time
    
48.         print('%s程序共计%.3f秒' % (func.__name__,total_time))
    
49. 
    
50.     return int_time
    
51. 
    
52. 
    
53. @debug
    
54. def for_work(func, numbers):
    
55.     """ 顺序执行工作 """
    
56.     for n in numbers:
    
57.         func(n)
    
58. 
    
59. 
    
60. @debug
    
61. def thread_work(func, numbers):
    
62.     """ 并发 """
    
63.     th = []
    
64.     for n in numbers:
    
65.         t = Thread(target=func,args=(n,))
    
66.         th.append(t)
    
67.         t.start()
    
68.         t.join()
    
69. 
    
70. 
    
71. @debug
    
72. def process_work(func, numbers):
    
73.     """ 并行 """
    
74.     th = []
    
75.     for n in numbers:
    
76.         t = Process(target=func,args=(n,))
    
77.         th.append(t)
    
78.         t.start()
    
79.         t.join()
    
80. 
    
81. 
    
82. def main():
    
83.     numbers = (100000, 200000, 300000, 400000, 500000, 600000, 700000, 800000)
    
84.     # CPU密集型
    
85.     for_work(sum_primes, numbers)
    
86.     thread_work(sum_primes, numbers)
    
87.     process_work(sum_primes, numbers)
    
88. 
    
89.     # IO密集型
    
90.     for_work(io, numbers)
    
91.     thread_work(io, numbers)
    
92.     process_work(io, numbers)
    
93. 
    
94. 
    
95. if __name__ == "__main__":
    
96.     main()
    

复制代码

跳转到最佳答案楼层

Twilight6

第一个报错是因为你参数少了两，我也不懂传入的对不对，对修饰符和线程了解很少，所以代码几乎看不懂：

1. func()  # <--这边要两个参数才能运行

复制代码

瞎改成：

1. func(*args,**kwargs)

复制代码

完整代码：

1. import time
   
2. from threading import Thread
   
3. from multiprocessing import Process
   
4. 
   
5. 
   
6. def is_prime(n):
   
7.     """ 判断n是否为素数 """
   
8.     if n == 1:
   
9.         return False
   
10.     else:
    
11.         assert isinstance(n, int)
    
12.         num = int(n ** 0.5)
    
13.         for i in range(2, num + 1):
    
14.             if n % i == 0:
    
15.                 return False
    
16.         return True
    
17. 
    
18. 
    
19. def sum_primes(n):
    
20.     """ 计算小于等于n的素数之和 """
    
21.     sump = 0
    
22. 
    
23.     for i in range(n + 1):
    
24.         if is_prime(i) == True:
    
25.             sump = sump + i
    
26. 
    
27.     print(sump, end=" ")
    
28.     return sump
    
29. 
    
30. 
    
31. def io(n):
    
32.     """ 模拟IO密集型 """
    
33.     time.sleep(1)
    
34.     print(n, end=" ")
    
35.     return n
    
36. 
    
37. 
    
38. def debug(func):
    
39.     """ 装饰器，记录运行时间
    
40.     提示：在函数执行前执行start_time = time.time()获取开始时间
    
41.          在函数执行后执行end_time = time.time()获取完成时间
    
42.     """
    
43.     def int_time(*args, **kwargs):
    
44.         start_time = time.time()  # 程序开始时间
    
45.         func(*args,**kwargs)
    
46.         end_time = time.time()  # 程序结束时间
    
47.         total_time = end_time - start_time
    
48.         print('%s程序共计%.3f秒' % (func.__name__,total_time))
    
49. 
    
50.     return int_time
    
51. 
    
52. 
    
53. @debug
    
54. def for_work(func, numbers):
    
55.     """ 顺序执行工作 """
    
56.     for n in numbers:
    
57.         func(n)
    
58. 
    
59. 
    
60. @debug
    
61. def thread_work(func, numbers):
    
62.     """ 并发 """
    
63.     th = []
    
64.     for n in numbers:
    
65.         t = Thread(target=func,args=(n,))
    
66.         th.append(t)
    
67.         t.start()
    
68.         t.join()
    
69. 
    
70. 
    
71. @debug
    
72. def process_work(func, numbers):
    
73.     """ 并行 """
    
74.     th = []
    
75.     for n in numbers:
    
76.         t = Process(target=func,args=(n,))
    
77.         th.append(t)
    
78.         t.start()
    
79.         t.join()
    
80. 
    
81. 
    
82. def main():
    
83.     numbers = (100000, 200000, 300000, 400000, 500000, 600000, 700000, 800000)
    
84.     # CPU密集型
    
85.     for_work(sum_primes, numbers)
    
86.     thread_work(sum_primes, numbers)
    
87.     process_work(sum_primes, numbers)
    
88. 
    
89.     # IO密集型
    
90.     for_work(io, numbers)
    
91.     thread_work(io, numbers)
    
92.     process_work(io, numbers)
    
93. 
    
94. 
    
95. if __name__ == "__main__":
    
96.     main()
    

复制代码