マルチプロセスでの新しいプロセスはメインスレッドで実行できますか？

Question

python3（iperf3）で使用する必要があるライブラリの1つは、ライブラリ 'run'の機能がメインスレッドで実行されるである必要があります。

マルチプロセスの新しいプロセスであるライブラリがプロセスのメインスレッドを使用できるようにするためにいくつかのテストを行っていますが、上記のスニペットでは新しい 'メインスレッド'プロセス。

フォークされたプロセスを新しいプロセスのメインスレッドとして実行するには、どのような方法が推奨されますか？それは可能ですか？ Celeryのようなシステムはこれを手助けしますか？私はFlaskアプリからこれを実行する予定です。

ありがとうございます！

#! /usr/bin/python3 

import threading 
import multiprocessing as mp 


def mp_call(): 
    try: 
     print("mp_call is mainthread? {}".format(isinstance(threading.current_thread(), threading._MainThread))) 
    except Exception as e: 
     print('create iperf e:{}'.format(e)) 


def thread_call(): 
    try: 
     print("thread_call is mainthread? {}".format(isinstance(threading.current_thread(), threading._MainThread))) 
     p = mp.Process(target=mp_call, args=[]) 
     p.daemon = False 
     p.start() 
     p.join() 
     print('Process ended') 
    except Exception as e: 
     print('thread e:{}'.format(e)) 

t = threading.Thread(target=thread_call) 
t.daemon = False 
t.start() 
t.join() 
print('Thread ended') 

Answer 1

は、実際には、すべてのスレッドがフォーク後に死んでいる、あなたは、現在のスレッドで新しい「メイン」スレッドを取得します、あなたのチェック方法は間違っています。

assert threading.current_thread() == threading.main_thread() 

main thread got replacedために、もはやサブプロセスフォーク、_MainThreadサブクラス後：threading._MainThreadではなくthreading.main_thread()を使用し、パブリックAPIではありません。