Pythonでの並列処理の簡単な例

Question

私はマルチプロセッシングが私にとって新しいものだと言います。私はそれについていくつか読んだが、それは私をもっと混乱させる。私は簡単な例でそれを理解したい。最初の関数に2つの関数があると仮定しましょう。変数 'a'をインクリメントして 'number'変数に代入します。次に、最初に関数を開始し、1秒ごとに 'number'変数を出力します。次のようになります。

global number 

def what_number(): 
    a=1 
    while True: 
     a+=1 
     number=a 

def read_number(): 
    while True: 
     --> #here I need to start 'what_number' function <-- 
     time.sleep(1) 
     print(number) 


if __name__ == "__main__": 
    read_number() 

どうすればいいですか？それを行うための簡単かつ適切な方法はありますか？

UPDATE：

私は本当にthankfullだが、それは私がしたい正確に何でないnoxdafox答えを見ました。まず第一に、私は最初の関数（noxdafoxコードの 'main'）に値を送ることは望ましくありません。二番目に私はすべての価値を得たくないので、クーネはうまくいかないでしょう。 whileループの2番目のそれぞれの後に取得する必要があります。 uは上記のコードを実行した場合、あなたが何かを得る

import multiprocessing 
import time 

number = 0 


def child_process(): 
    global number 
    while True: 
     number += 1 
     print(number) 


def main(): 
    process = multiprocessing.Process(target=child_process) 
    process.start() 

    while True: 
     print("should get same number:",number) 
     time.sleep(0.001) 

if __name__ == "__main__": 
    main() 

：

をしかし、この青の値が同じである必要があり、選択したコードのようなものでなければなりません！それが一番の問題だ:)混沌

Answer 1

これは時間がかかりますが、わかりました。すべてそれは約Sharing state between processesだった今すべてそれは魅力のように動作します。コード：

from multiprocessing import Process, Value 
import time 


def child_process(number): 
    number.value = 0 
    while True: 
     number.value += 1 
     #print(number) 


def main(): 
    num = Value('i') 
    process = Process(target=child_process, args=(num,)) 
    process.start() 
    while True: 
     print("should get same number:", num.value) 
     time.sleep(1) 

if __name__ == "__main__": 
    main() 

Answer 2

のプロセスが別のメモリアドレス空間に住んでいるとして、あなたは変数を共有することができないため

P.S申し訳ありません。さらに、グローバル変数を間違って使用しています。 Hereグローバル変数の使用方法の例を見ることができます。

プロセス間で情報を共有する最も簡単な方法は、PipeまたはQueueです。

import multiprocessing 

def child_process(queue): 
    while True: 
     number = queue.get() 
     number += 1 
     queue.put(number) 

def main(): 
    number = 0 
    queue = multiprocessing.Queue() 
    process = multiprocessing.Process(target=child_process, args=[queue]) 
    process.start() 

    while True: 
     print("Sending %d" % number) 
     queue.put(number) 

     number = queue.get() 
     print("Received %d" % number) 

     time.sleep(1) 

if __name__ == "__main__": 
    main()