快捷導(dǎo)航

python中start和run方法的區(qū)別

更新時(shí)間：2022年02月13日 08:57:23 作者：小槿12358

大家好，本篇文章主要講的是python中start和run方法的區(qū)別，感興趣的同學(xué)趕快來(lái)看一看吧，對(duì)你有幫助的話(huà)記得收藏一下

結(jié)論：?jiǎn)?dòng)線(xiàn)程，如果對(duì)target進(jìn)行賦值，并且沒(méi)有重寫(xiě)run方法，則線(xiàn)程start的時(shí)候會(huì)直接調(diào)用target中對(duì)應(yīng)的方法

具體代碼如下：
1、初始化一個(gè)線(xiàn)程

threading.Thread.__init__(self,target=thread_run())

def __init__(self, group=None, target=None, name=None,
                 args=(), kwargs=None, *, daemon=None):
        assert group is None, "group argument must be None for now"
        if kwargs is None:
            kwargs = {}
        self._target = target
        self._name = str(name or _newname())
        self._args = args
        self._kwargs = kwargs

2、調(diào)用start啟動(dòng)線(xiàn)程
最終調(diào)用_start_new_thread方法，self._bootstrap作為傳參

thread1.start()
    def start(self):
        if not self._initialized:
            raise RuntimeError("thread.__init__() not called")
        if self._started.is_set():
            raise RuntimeError("threads can only be started once")
        with _active_limbo_lock:
            _limbo[self] = self
        try:
            _start_new_thread(self._bootstrap, ())
        except Exception:
            with _active_limbo_lock:
                del _limbo[self]
            raise
        self._started.wait()

3、_start_new_thread等同于啟動(dòng)一個(gè)新線(xiàn)程，并在新線(xiàn)程中調(diào)用回調(diào)函數(shù)

_start_new_thread = _thread.start_new_thread
def start_new_thread(function: Callable[..., Any], args: tuple[Any, ...], kwargs: dict[str, Any] = ...) -> int: ...

4、執(zhí)行的回調(diào)函數(shù)就是上文傳入的self._bootstrap， _bootstrap方法直接調(diào)用_bootstrap_inner()，而bootstrap_inner則調(diào)用run方法

def _bootstrap_inner(self):
    try:
        self._set_ident()
        self._set_tstate_lock()
        if _HAVE_THREAD_NATIVE_ID:
            self._set_native_id()
        self._started.set()
        with _active_limbo_lock:
            _active[self._ident] = self
            del _limbo[self]

        if _trace_hook:
            _sys.settrace(_trace_hook)
        if _profile_hook:
            _sys.setprofile(_profile_hook)
        try:
            self.run()

5、最終調(diào)用run方法

 def run(self):
        try:
            if self._target:
                self._target(*self._args, **self._kwargs)
        finally:
            # Avoid a refcycle if the thread is running a function with
            # an argument that has a member that points to the thread.
            del self._target, self._args, self._kwargs

結(jié)論：
如果run方法被重寫(xiě)，則直接調(diào)用重寫(xiě)的run方法
如果run方法沒(méi)有被重寫(xiě)，并且target被定義，則會(huì)直接調(diào)用線(xiàn)程創(chuàng)建時(shí)候的target方法，否則什么也不做

此處遇到一問(wèn)題：
指定target參數(shù)，在執(zhí)行過(guò)程中，打印的進(jìn)程名mainthread（主進(jìn)程），而不是之前所賦的進(jìn)程名
threading.Thread.init(self,target=thread_run())
分析后發(fā)現(xiàn)賦予target的是執(zhí)行的函數(shù)體，因此會(huì)先執(zhí)行thread_run函數(shù)，執(zhí)行結(jié)束后，將thread_run的返回值賦給了target，因?yàn)閠hread_run沒(méi)有返回值，因此target的值是None，如果此時(shí)沒(méi)有重寫(xiě)run函數(shù)，那么線(xiàn)程什么都不會(huì)做。 thread_run的執(zhí)行是在主線(xiàn)程，而不是我們所認(rèn)為的在子線(xiàn)程中執(zhí)行thread_run

def thread_run():
    print ("overwrite: 開(kāi)始線(xiàn)程:" + threading.current_thread().name)
    time.sleep(2)
    print ("overwrite: 退出線(xiàn)程:" + threading.current_thread().name)

class myThread (threading.Thread):
    def __init__(self, threadID, name, delay):
        threading.Thread.__init__(self,target=thread_run())
        self.threadID = threadID
        self.name = name
        self.delay = delay
        thread1.start()

thread1.join()
print ("退出主線(xiàn)程")

運(yùn)行結(jié)果：