pythonでmultiprocessingのpoolでNameError: name '' is not definedのエラーが出る

Question

前提・実現したいこと

pythonを勉強していてモンテカルロ木探索を使ったオセロを実装しました。
その際に複数の探索結果を出したいと思い、multiprocessingのpoolを使って
同時に複数の探索を行わせようとしました。

その時のコードは以下になります。

　　#どこに石を置くかを決定する
　　def put_stone(self):

　　　　　　　　　　略

　　　　p = Pool(8) #同時に最大8個の子プロセス

　　　　for i in range(7):
	　　　　p.apply_async(Player_MCTS, args=(None,i+1,))
		
	　　　　p.close()
	　　　　p.join()
　　　　"""質問には関係ないところです
　　　　for m in range(3):
	　　　　if len(playerMCTS) < m+1:
	　　　　　　　break
　　　　"""
　　　　　　　　略

　　#モンテカルロ木探索で手を決定する
　　def Player_MCTS(self, times):
		
        global playerMCTS
		print('Run task {}'.format(times))
		playerMCTS = pMCTS.mctsNextPosition(self.board, DEEP * times)
		print("探索結果", playerMCTS)
　　　　　　　　

一つ目のfor文で８個作ったプロセスにそれぞれ関数Player_MCTSで探索させようとしています。
Player_MCTSでは違うpyファイルの中のモンテカルロ木探索をハイパーパラメータのDEEPと回数で積算で探索の深さを決定し探索させます。

ここでの問題としてこれを実行すると、

File "ReversiUI.py", line 131, in put_stones
    p.apply_async(Player_MCTS, args=(None,i+1,))
NameError: name 'Player_MCTS' is not defined

というエラーがでて関数がないよと言われます。
なにが原因でどのようにしたら解決するのか全く分からないので教えていただきたいです。
よろしくお願いします。

追記

エラーの部分である
p.apply_async(Player_MCTS, args=(None,i+1,))
を
p.apply_async(self.Player_MCTS, args=(None,i+1,))
に変更して実行したところ、

 File "ReversiUI.py", line 187, in put_stones
    if len(playerMCTS1) < m+1:
NameError: name 'playerMCTS' is not defined

というエラーが出て、
poolのところをスルーしてしまいました。
関数のPlayer_MCTSを通らない結果出力されるはずのplayerMCTSが定義されず、
エラーが出ているのかなと思います。

追記
このコードは例文を参考に実装しました。
例文のソースコードは以下のようになります。

from multiprocessing import Pool
import os
import time
import random


def long_time_task(self,name):
    print('Run task {} ({})...'.format(name, os.getpid()))
    start = time.time()
    time.sleep(3)
    end = time.time()
    print('Task {} runs {} seconds.'.format(name, (end - start)))


def main(self):
	print('Parent process {}.'.format(os.getpid()))
	p = Pool(8)  # 同時に最大4個の子プロセス
	for i in range(8):
		p.apply_async(long_time_task, args=(None,i+1,))
	# 非同期処理のため、親プロセスは子プロセスの処理を待たずに、
	# 次のprintをする
	print('Waiting for all subprocesses done...')
	p.close()
	p.join()

	
	print('All subprocesses done.')

if __name__ == '__main__':
	main(None)

このソースコードはうまく実行できます。

問題のソースコードのエラー文を見るにplayerMCTSは関数の名前ではなく、引数の名前として探しているから見つからないのでしょうか？

例文と同じコードを使用してうまくいかない場合、どこを確認すればいいのかわかりません。

追記
最初のソースコードだとわかりづらいかなと思ったので同じような簡易版のソースコードを作成しました。

import time
from multiprocessing import Pool


class Main():

    def main(self):
        # Pool()を定義
        p = Pool()

    # プロセスを2つ非同期で実行
        a = 3
        b = 5
        
        result = p.apply_async(nijou, args=(None, a))
        result2 = p.apply_async(nijou, args=(None, b))


    # 1秒間隔で終了チェックして終了したら結果を表示
        for k in range(5):
            if result.ready():
                break
        print(result.get())
        print(result2.get())
        
    


    def nijou(self,inputs):
        x = inputs
        print('input: %d' % x)
        time.sleep(8)
        retValue = x * x
        print('double: %d' % retValue)
        return(retValue)

class MainStart():
    def __init__(self):
        Main.main(None)
        

if __name__ == "__main__":

    app = MainStart()

これを実行した際のエラー文が以下になります。

Traceback (most recent call last):
  File "Test.py", line 44, in <module>
    app = MainStart()
  File "Test.py", line 39, in __init__
    Main.main(None)
  File "Test.py", line 15, in main
    result = p.apply_async(nijou, args=(None, a))
NameError: name 'nijou' is not defined

こちらでも定義してあるはずのnijouがないよと言われます。
かなり短いソースコードに絞れたのでこの中に原因があるのかなと思っています。

Answer 1

その1

「なにが原因でどのようにしたら解決するのか全く分からないので教えていただきたい」

エラーのとおりそんな関数はありませんよ。と言っています。
提示されていないのでわかりませんが、ここに出てくるdefが、クラス内のメソッド定義だったということであれば、クラス内のメソッドをアクセスするには、selfが必要ということです。
追記で書いてあるとおりです。

その2

poolのところをスルーしてしまいました。

関数のPlayer_MCTSを通らない結果出力されるはずのplayerMCTSが定義されず、
エラーが出ているのかなと思います。

多分、コプロセス内で例外が発生しているのでしょう。子プロセス内で例外が発生しても、親プロセスは影響を受けませんし、どこにも表示されません。
まずはこの関数を単一プロセスで実行して動作を確認するのがいいと思います。

その3

playerMCTSは関数の名前ではなく、引数の名前

「playerMCTS」は関数名なんですか？ それをglobalで宣言している？
どう見ても、変数しかもglobal変数として扱おうとしているように見えます。

Comments

[_toy]

丁寧な回答ありがとうございます。
その２の単一プロセスは動作確認済みで実行時間が長いため、並列処理を行おうと考え実装しました。

その３は誤字です。申し訳ないです。
正しくはPlayer_MCTSは関数ではなく、引数として扱われているのか、です。
子プロセスのエラーを検知する方法はないでしょうか？

[TakaiY]

回答に書きましたが、Player_MCTS がクラスの中のメソッドであれば、self.Player_MCTS とするのが正しい書き方です。
こうすることで、ちゃんと呼び出されていますが、正常に実行されていない可能性が高いです。

全てのプロセスで結果を、同一の playerMCTS に入れるようになっているところとか、そのplayerMCTS がgolobalであるところとか、通常やらないようなことになっています。

まずは、結果を破棄する形で実装してみて、print文などで動作することを確認してみては。
そのあと、結果の取得は、ファイルで受け取るとか、multiprocessing.map()を使うとか、queueを使うとか、いろいろあるのでそういうのを使うことをお勧めします。

[_toy]

実装の部分で普通やらないようなコードが書かれているから、何かしらのエラーが出ている可能性があるということですね。
ありがとうございます。
それを考えて、同じような状況で簡易化したものを作成しました。
編集して追記しますが、同じエラーが出ます。
もし、この条件下だから使えないなどご存じでしたら、教えてほしいです。

[TakaiY]

同じエラーは
NameError: name 'playerMCTS' is not defined
ですか？ であれば、そもそもplayerMCTSに値を保存するような作りがだめなので、そこも含めて直さないとだめですよ。

[_toy]

いえ、追記の方のエラーではなく、
NameError: name 'Player_MCTS' is not defined
のエラーです。

[TakaiY]

その「Player_MCTS」はクラスの中のメソッドですか？ であれば、self.Plaier_MCTSと書く必要があります。
そうでなくて、not definedと出るのであれば、ファイルの構成などに問題があります。

ただ、今、ちょっと知らべたところ、クラスのメソッドをmultiprocessin.Poolで 並列化するのは難しいようです。
https://qiita.com/ponnhide/items/170c98fe5aff2f6ebd2e
この記事ではできないとありますが、「こうすればできる」という情報を乗せているところもあります。

ということで、とりあえずクラスでない実装にすることをお勧めします。

[_toy]

なるほど、クラスではできないのですね。
違う方法を考えてみます。
丁寧に説明していただきありがとうございました。