如何在python中的同一對象中的另一個線程內產生一個線程？

Question

我正在使用加載Cygwin的香草Python 2.7我想要能夠產生調用頂級函數的線程子類，並且頂級函數會生成單獨的線程來調用子級函數。下面是僞代碼

import threading 

#!/usr/bin/python 
import threading 

class Server(threading.Thread): 
    def __init__(self, threadID, target): 
     self.__threadID = threadID 
     self.__target = target 
     threading.Thread.__init__(self) 

    # Function called when the thread's start() function is called 
    def run(self): 
     self.target() 
     pass 

    # This is the top level function called by other objects 
    def reboot(self): 
     # I want this function to spawn two threads 
     # - First thread calls the __powerDown() function 
     # - Secod thread calls the __powerUp() function, and pends 
     # until __powerDown() thread finishes 
     pass 

    def __powerDown(self): 
     # What to put here? 
     pass 

    def __powerUp(self): 
     # What to put here? 
     pass 

    __threadID = '' 
    __target = None 


# Code calling above code 
server = Server(123, reboot) # Will this work? 

Answer 1

是這樣的嗎？

import threading 

class Server(threading.Thread): 
    # some code 

    # This is the top level function called by other objects 
    def reboot(self): 
     # perhaps add a lock 
     if not hasattr(self, "_down"): 
      self._down = threading.Thread(target=self.__powerDown) 
      self._down.start() 
      up = threading.Thread(target=self.__powerUp) 
      up.start() 

    def __powerUp(self): 
     if not hasattr(self, "_down"): 
      return 
     self._down.join() 
     # do something 
     del self._down 

Answer 2

有很多方法可以做到這一點，我最熟悉的線程池，他們有調用線程，並加入他們一個非常簡單的界面...

from multiprocessing.pool import ThreadPool 

# This is the top level function called by other objects 
def reboot(self): 
    # setup your thread pool: 
    reboot_pool = ThreadPool() 
    # - First thread calls the __powerDown() function 
    power_down = reboot_pool.apply_async(self.__powerDown()) 
    # this will block until it finishes 
    power_down.get() 
    # - Secod thread calls the __powerUp() function 
    power_up = reboot_pool.apply_async(self.__powerUp()) 
    # block until __powerUp() thread finishes 
    power_up.get() 

def __powerDown(self): 
    # What to put here? 
    pass 

def __powerUp(self): 
    # What to put here? 
    pass 

它與你說明它的方式略有不同，因爲我首先調用powerDown，等待它完成，然後調用powerUp，但是我認爲它完成了這個想法。