下面的代码示例是我尝试创建的一个小脚本。在这个脚本中,有两个函数:
我创建了两个线程threa_01和thread_02,并告诉它们执行我想要的函数。在args变量中,我发送了要计算的数组(args=array)。在目标变量中,我发送了特定线程要运行的函数名称(
不幸的是,当我执行时,我遇到了以下问题: 问题
calculate_the_square(takes_the_given_array)
和 calculate_the_cube(takes_the_given_array)
。我创建了两个线程threa_01和thread_02,并告诉它们执行我想要的函数。在args变量中,我发送了要计算的数组(args=array)。在目标变量中,我发送了特定线程要运行的函数名称(
target=calculate_the_square
或target=calculate_the_cube
)。然后我开始执行线程,并让它们加入。不幸的是,当我执行时,我遇到了以下问题: 问题
Exception in thread Thread-1:
Traceback (most recent call last):
File "C:\Program Files (x86)\Python37-32\lib\threading.py", line 917, in _bootstrap_inner
self.run()
File "C:\Program Files (x86)\Python37-32\lib\threading.py", line 865, in run
self._target(*self._args, **self._kwargs)
TypeError: calculate_the_square() takes 1 positional argument but 6 were given
Exception in thread Thread-2:
Traceback (most recent call last):
File "C:\Program Files (x86)\Python37-32\lib\threading.py", line 917, in _bootstrap_inner
self.run()
File "C:\Program Files (x86)\Python37-32\lib\threading.py", line 865, in run
self._target(*self._args, **self._kwargs)
TypeError: calculate_the_cube() takes 1 positional argument but 6 were given
Process finished with exit code 0
期望的输出结果(必须是混合的,但我写了通用结果而不是多线程的)
Cube result: 5832
Cube result: 778688
Cube result: 2000376
Cube result: 281011375
Cube result: 967361669
Cube result: 1006012008
Square result: 324
Square result: 8464
Square result: 15876
Square result: 429025
Square result: 978121
Square result: 1004004
The program finished in : ...... SOME TIME
代码示例
import time
import threading
def calculate_the_square(variables):
for var in variables:
time.sleep(0.5) # Insert a sleep just to count the time that needs to be completed
print("Square result: ", var*var)
def calculate_the_cube(variables):
time.sleep(0.5) # Insert a sleep just to count the time that needs to be completed
for var in variables:
print("Cube result: ", var*var*var)
keeping_time = time.time() # Keeping the starting time
array = [18, 92, 126, 655, 989, 1002] # Random given numbers.
thread_01 = threading.Thread(target=calculate_the_square, args=(array)) # Creating threadh No1 and the target make this thread to focus on this function, sending the value that is saved in tha variable args.
thread_02 = threading.Thread(target=calculate_the_cube, args=(array)) # Creating threadh No2 and the target make this thread to focus on this function, sending the value that is saved in tha variable args.
thread_01.start() # Starting the thread 1
thread_02.start() # Starting the thread 2
thread_01.join() # Waits until the first thread is finished. Better switching between the threads. Maybe not now (only 2 threads) but if we had 10 and more it would be helpful.
thread_02.join()
print("The program finished in :", time.time()-keeping_time)
你能帮我解决这个问题吗?我做错了什么吗?
提前感谢您的时间!
calculate_the_square
函数接受一个数组和一个字符串作为参数,那么你需要将args
设置为args=(variables, "example string")
,并将函数声明为def calculate_the_square(variables, str):
。 - kgorak