1

OneWireセンサー（ds18b20）を使用して温度を読み取り、それをPIアルゴリズムで使用してSSRリレーを制御します。2つの関数間のパイプを使用して温度を送信し、「Reg」関数をできるだけ高速に実行したいと思います。パイプを使用しない場合、Reg関数は温度関数を待機し（0.75秒を使用）、出力が間違っています...パイプ関数の使用方法を教えてもらえますか？

コード：

import time
import RPi.GPIO as GPIO
import os

GPIO.setwarnings(False)
GPIO.setmode(GPIO.BCM)
GPIO.setup(22, GPIO.OUT)


def temperatur(self):
 while True:

    tfile = open("/sys/bus/w1/devices/28-00000433f810/w1_slave")
    text = tfile.read()
    tfile.close()
    secondline = text.split("\n")[1]
    temperaturedata = secondline.split(" ")[9]
    temp2 = float(temperaturedata[2:])
    self.temp = temp2 / 1000
    print self.temp


def reg(self):

  while True:

    ek = self.ref - self.temp
    P_del = self.Kp * ek
    I_del = ((self.Kp * self.Syklustid) / self.Ti) * ek
    Paadrag = P_del + I_del
    if Paadrag > 100:
        Paadrag = 100
    if Paadrag < 0:
        Paadrag = 0    
    print "Paadrag: ", Paadrag, "  Temperatur: ", self.temp
    duty = Paadrag / 100.0
    on_time = self.Syklustid * (duty)
    off_time = self.Syklustid * (1.0-duty)
    print "On_time: ", on_time, "  Off_time: ", off_time
    GPIO.output(22, GPIO.HIGH)
    time.sleep(on_time)
    GPIO.output(22, GPIO.LOW)
    time.sleep(off_time

if __name__ == '__main__':
4

1 に答える 1

1

これは、Python のドキュメントから直接引用したものです: http://docs.python.org/2/library/multiprocessing.html

from multiprocessing import Process, Pipe

def f(conn):
    conn.send([42, None, 'hello'])
    conn.close()

if __name__ == '__main__':
    parent_conn, child_conn = Pipe()
    p = Process(target=f, args=(child_conn,))
    p.start()
    print parent_conn.recv()   # prints "[42, None, 'hello']"
    p.join()

共有状態を使用すると、より良い結果が得られました。特に温度のような単純なデータの場合 (私が推測する数値 - 複雑なカスタム オブジェクトなどではありません) ここに小さな例を示します (これも python docs でさらに見つけることができます)

#import stuff
from multiprocessing import Process, Manager

# Create a shared dictionary of paremeters for both processes to use 
manager = Manager()
global_props = manager.dict()
# SuperImportant - initialise all parameters first!!
global_props.update({'temp': 21.3})

def functionOne(global_props):
    # Do some stuff read temperature
    global_props['temp'] = newVal

def functionTwo(global_props):
    temp = global_props['temp']
    # Do some stuff with the new value

# assign listeners to the two processes, passing in the properties dictionary

handlerOne = functionOne  # This can also be a class in which case it calls __init__()
handlerTwo = functionTwo
processOne = Process(target=handlerOne, 
    args=(global_props))
processTwo = Process(target=handlerTwo, 
    args=(global_props))

# Start the processes running...
processOne.start()
processTwo.start()
processOne.join() 
processTwo.join()
于 2013-02-17T15:08:34.387 に答える