multiprocessingをpython3で使うときに2つの関数のうち片方の関数の結果をリアルタイムで共有したいです

Question

前提・実現したいこと

パイソン３で並行処理を利用して2つの関数を定義して使っていますが、片方はarduinoを利用して可変抵抗の値をデジタルの0~1023で読み取っています。
もう片方のプログラムでその値を読み取りながら利用してモーターコントローラの制御に使用してモーターの回転速度を変えるためDuty比が可変になるようにしたいです。
どうかお助け願います。よろしくお願いいたします。

発生している問題・エラーメッセージ

2つの関数の間で変数の共有をすればいいのではと考えてmultiprocessingで共有メモリーのValueクラスを用いてみましたがうまいこと共有できません。エラーメッセージは以下のものです。

Traceback (most recent call last):
  File "/home/pi/並行処理(multiprocessing).py", line 45, in <module>
    Process(target = A()),
  File "/home/pi/並行処理(multiprocessing).py", line 16, in A
    shared_count.value = (int(line.strip().decode('utf-8')))
NameError: name 'shared_count' is not defined

該当のソースコード

import serial
from multiprocessing import Pool, Value, Process
import RPi.GPIO as GPIO
import sys
import time

GPIO.setmode(GPIO.BCM)
GPIO.setup(14, GPIO.OUT)
GPIO.setup(15, GPIO.OUT)
GPIO.setup(18, GPIO.OUT)


def A():
    ser = serial.Serial('/dev/ttyACM0', 9600, timeout = None)
    line = ser.readline()
    shared_count.value = (int(line.strip().decode('utf-8')))
    MAX_TIME = 50
    st = time.time()
    while True:
        print(int(line.strip().decode('utf-8')))
        time.sleep(0.01)
        if (time.time() - st) > MAX_TIME:
            sys.exit()
        
       
def B():
    p = GPIO.PWM(18, 1)
    Hz = 700
    p.ChangeFrequency(Hz)
    duty = 0.0
    p.start(duty)
    while True:
        global shared_count, shared_value
        shared_count = count
        shared_value = value
        duty = (count / 10) % 101
        p.ChangeDutyCycle(duty)
        time.sleep(0.1)
        GPIO.output(14, True)
        GPIO.output(15, False)
        


jobs = [
    Process(target = A()),
    Process(target = B())
    ]

for j in jobs:
    j.start()
    
for j in join:
    j.join()



    
    
    
    
        

試したこと

プログラミングにまったく知識がない状態なので試したことは文の上下を入れ替えたり程度です・・・

補足情報（FW/ツールのバージョンなど）

ツールは
Arduino　Uno
Raspberry3
モータードライバはTOSHIBA TA7291Pです

Answer 1

シリアル通信の結果を持ってきてPWMを変化させるだけなら、そもそもmultiprocessingもマルチスレッドも不要で、単なるループの処理で十分だと思いますが

Comments

[calpis123]

ご回答ありがとうございます！
頑張ります！

Answer 2

質問文のコードは共有メモリを使えていません。というか、それ以前に

jobs = [
    Process(target = A()),
    Process(target = B())
    ]

でtargetにはA(), B()の結果が代入されているので、マルチプロセスの処理すら動いてません。target = A等とする必要があります。

---

やりたいこと的にはマルチスレッドで十分なのでは。それなら、値の共有には単にグローバル変数を使えば良いです。

参考：
Pythonの並列・並行処理サンプルコードまとめ - Qiita
pythonでマルチスレッドで処理して各スレッドの結果を受け取る - Qiita

Comments

[calpis123]

ご回答ありがとうございます！もし良かったら私のやりたいと思うことを実現するためにグローバル変数をどのように使えばいいか少しコードを教えてもらえたりって出来ますか？
サイトを参考にさせて頂いたのですがどう利用していいかわからず困りまして（；^ω^）

[hayataka2049]

ラズパイとアルディーノは触ったことがないので、申し訳ありませんが具体的な内容についてはお答えできません;
頑張ってください！