blocks|key|1025828|text|您是否覆盖了run()方法？如果您重写了__init__，您是否确保调用了基本threading.Thread.__init__()|type|unstyled|depth|inlineStyleRanges|offset|length|style|CODE|entityRanges|data|1025829|在启动两个线程后，主线程是否继续在子线程上无限期地工作/阻塞/联接，以便在子线程完成任务之前主线程的执行不会结束？|1025830|最后，您是否得到了任何未处理的异常？|1025831|entityMap^0|K|8|13|R|0|0|0^^$0|@$1|2|3|4|5|6|7|L|8|@$9|M|A|N|B|C]|$9|O|A|P|B|C]]|D|@]|E|$]]|$1|F|3|G|5|6|7|Q|8|@]|D|@]|E|$]]|$1|H|3|I|5|6|7|R|8|@]|D|@]|E|$]]|$1|J|3|-4|5|6|7|S|8|@]|D|@]|E|$]]]|K|$]]

Did you override the run() method? If you overrided <code>__init__</code>, did you make sure to call the base <code>threading.Thread.__init__()</code>?

After starting the two threads, does the main thread continue to do work indefinitely/block/join on the child threads so that main thread execution does not end before the child threads complete their tasks?

And finally, are you getting any unhandled exceptions?

blocks|key|1240574|text|您可以在Thread构造函数中使用target参数来直接传入将被调用的函数，而不是run。|type|unstyled|depth|inlineStyleRanges|offset|length|style|CODE|entityRanges|data|1240575|entityMap^0|4|6|H|6|15|3|0^^$0|@$1|2|3|4|5|6|7|H|8|@$9|I|A|J|B|C]|$9|K|A|L|B|C]|$9|M|A|N|B|C]]|D|@]|E|$]]|$1|F|3|-4|5|6|7|O|8|@]|D|@]|E|$]]]|G|$]]

You can use the <code>target</code> argument in the <code>Thread</code> constructor to directly pass in a function that gets called instead of <code>run</code>.

blocks|key|1025879|text|你不需要使用Thread的子类来实现这一点--看看我在下面发布的简单示例，看看是如何做到的：|type|unstyled|depth|inlineStyleRanges|offset|length|style|CODE|entityRanges|data|1025880|from+threading+import+Thread
from+time+import+sleep

def+threaded_function(arg):
++++for+i+in+range(arg):
++++++++print("running")
++++++++sleep(1)


if+__name__+==+"__main__":
++++thread+=+Thread(target+=+threaded_function,+args+=+(10,+))
++++thread.start()
++++thread.join()
++++print("thread+finished...exiting")|code-block|syntax|javascript|1025881|在这里，我展示了如何使用线程模块来创建一个调用普通函数作为其目标的线程。您可以看到我如何在线程构造函数中向它传递所需的任何参数。|1025882|entityMap^0|6|6|0|0|0^^$0|@$1|2|3|4|5|6|7|O|8|@$9|P|A|Q|B|C]]|D|@]|E|$]]|$1|F|3|G|5|H|7|R|8|@]|D|@]|E|$I|J]]|$1|K|3|L|5|6|7|S|8|@]|D|@]|E|$]]|$1|M|3|-4|5|6|7|T|8|@]|D|@]|E|$]]]|N|$]]

You don't need to use a subclass of <code>Thread</code> to make this work - take a look at the simple example I'm posting below to see how:

<pre><code>from threading import Thread
from time import sleep

def threaded_function(arg):
 for i in range(arg):
 print("running")
 sleep(1)


if __name__ == "__main__":
 thread = Thread(target = threaded_function, args = (10, ))
 thread.start()
 thread.join()
 print("thread finished...exiting")
</code></pre>

Here I show how to use the threading module to create a thread which invokes a normal function as its target. You can see how I can pass whatever arguments I need to it in the thread constructor.

blocks|key|1025927|text|我尝试添加另一个join()，它似乎起作用了。以下是代码|type|unstyled|depth|inlineStyleRanges|entityRanges|data|1025928|from+threading+import+Thread
from+time+import+sleep

def+function01(arg,name):
++++for+i+in+range(arg):
++++++++print(name,'i---->',i,'\n')
++++++++print+(name,"arg---->",arg,'\n')
++++++++sleep(1)

def+test01():
++++thread1+=+Thread(target+=+function01,+args+=+(10,'thread1',+))
++++thread1.start()
++++thread2+=+Thread(target+=+function01,+args+=+(10,'thread2',+))
++++thread2.start()
++++thread1.join()
++++thread2.join()
++++print+("thread+finished...exiting")

test01()|code-block|syntax|javascript|1025929|entityMap^0|0|0^^$0|@$1|2|3|4|5|6|7|I|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|J|8|@]|9|@]|A|$E|F]]|$1|G|3|-4|5|6|7|K|8|@]|9|@]|A|$]]]|H|$]]

I tried to add another join(), and it seems worked. Here is code

<pre><code>from threading import Thread
from time import sleep

def function01(arg,name):
 for i in range(arg):
 print(name,'i----&gt;',i,'\n')
 print (name,"arg----&gt;",arg,'\n')
 sleep(1)

def test01():
 thread1 = Thread(target = function01, args = (10,'thread1', ))
 thread1.start()
 thread2 = Thread(target = function01, args = (10,'thread2', ))
 thread2.start()
 thread1.join()
 thread2.join()
 print ("thread finished...exiting")

test01()
</code></pre>

blocks|key|1240666|text|用threading实现多线程进程的简便方法|type|unstyled|depth|inlineStyleRanges|offset|length|style|CODE|entityRanges|data|1240667|相同的代码片段|1240668|import+threading

#function+which+takes+some+time+to+process+
def+say(i):
++++time.sleep(1)
++++print(i)

threads+=+[]
for+i+in+range(10):
++++
++++thread+=+threading.Thread(target=say,+args=(i,))

++++thread.start()
++++threads.append(thread)

#wait+for+all+threads+to+complete+before+main+program+exits+
for+thread+in+threads:
++++thread.join()|code-block|syntax|javascript|1240669|entityMap^0|1|9|0|0|0^^$0|@$1|2|3|4|5|6|7|O|8|@$9|P|A|Q|B|C]]|D|@]|E|$]]|$1|F|3|G|5|6|7|R|8|@]|D|@]|E|$]]|$1|H|3|I|5|J|7|S|8|@]|D|@]|E|$K|L]]|$1|M|3|-4|5|6|7|T|8|@]|D|@]|E|$]]]|N|$]]

the simple way to implement multithread process using <code>threading</code>
code snippet for the same
<pre><code>import threading

#function which takes some time to process 
def say(i):
 time.sleep(1)
 print(i)

threads = []
for i in range(10):
 
 thread = threading.Thread(target=say, args=(i,))

 thread.start()
 threads.append(thread)

#wait for all threads to complete before main program exits 
for thread in threads:
 thread.join()
</code></pre>

I have a script and I want one function to run at the same time as the other.

The example code I have looked at:

<pre class="lang-py prettyprint-override"><code>import threading

def MyThread (threading.thread):
 # doing something........

def MyThread2 (threading.thread):
 # doing something........

MyThread().start()
MyThread2().start()
</code></pre>

I am having trouble getting this working. I would prefer to get this going using a threaded function rather than a class.

This is the working script:

 <pre class="lang-py prettyprint-override"><code>from threading import Thread

class myClass():

 def help(self):
 os.system('./ssh.py')

 def nope(self):
 a = [1,2,3,4,5,6,67,78]
 for i in a:
 print i
 sleep(1)


if __name__ == "__main__":
 Yep = myClass()
 thread = Thread(target = Yep.help)
 thread2 = Thread(target = Yep.nope)
 thread.start()
 thread2.start()
 thread.join()
 print 'Finished'
</code></pre>

Creating Threads in python

我有一个脚本，我想让一个函数与另一个函数同时运行。我看过的示例代码如下：import threadingdef MyThread (threading.thread):    # doing something........def MyThread2 (threading.thread):    # doing so...

问在python中创建线程
EN

社区

活动

资源

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问在python中创建线程EN

社区

活动

资源

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问在python中创建线程
EN