Python: импорт переменной внутри бесконечного цикла - PullRequest
0 голосов
/ 29 декабря 2010

У меня есть два модуля, хост и сканер. Обе петли бесконечно для связи с последовательными портами. Я хочу импортировать переменную "bestchannel" из сканера в хост, но импортируя ее, цикл while внутри сканера запускается первым и циклически выполняется вечно. Я хочу, чтобы каждый модуль запускался отдельно, но мог отправлять друг другу данные в режиме реального времени. Возможно ли это?

(за пределами оперативной памяти)

Пример кода:

Host Loop----------------------------------------------
while True:
    ser.write( assemble("20","FF","FF","64","B") )
    sData = ser.read(100)
    if len(sData)>0:
        for i in range(0, len(sData)-17):
            if sData[i]==chr(1) and sData[i+1]==chr(20) and sData[i+2]==chr(int("A1", 16)):
                height = (ord(sData[i+16])*256+ord(sData[i+17]))/100
                print "Sensor ", ord(sData[i+12]), " is returning height ",
                height, "mm. The minnoisechan:",minchannel

Scanner Loop----------------------------------------------
while True:
    ser.write( scan("FF", "FF", str(scanlength)) )  #Channel Mask, Length
    time.sleep(scanlength+2.0)
    sData = ser.read(100)
    if len(sData)>0:
        for i in range(0, len(sData)-16):
            if sData[i]==chr(1) and sData[i+1]==chr(23) and sData[i+2]==chr(int("C5", 16)):
                for j in range(0, 16):
                    chan[j] = sData[i+5+j]
                    print "channel: ",j+11,"=",ord(chan[j])
                    if ord(chan[j])<minvalue:
                        minvalue=ord(chan[j])
                        minchannel=j+11
                count+=1
                print "count",count,"minvalue:",minvalue,"minchannel:",minchannel
                minvalue=999

Я хочу, чтобы minchannel со сканера был доступен для хоста.

образец кода находится в ссылке или внизу в ответе, извините, мне пришлось использовать другой браузер.

1 Ответ

1 голос
/ 29 декабря 2010

Итак, еще раз, если вы еще не изучали реализацию своего кода с использованием потоков, я бы посоветовал запустить два цикла одновременно.Так что-то вроде этого:

import threading
import Queue

def host(dataQueue):
    """
    Host code goes here.
    """
    # Check dataQueue for incoming data among other things...
    ....

def scanner(dataQueue):
    """
    Scanner code goes.
    """
    # Put data into dataQueue among other things...
    ....

if __name__ == 'main':
    dataQ = Queue.queue()
    hostThread = threading.Thread(target=host, name="Host", arg=(dataQ,))
    scannerThread = threading.Thread(target=scanner, name="Scanner", arg=(dataQ,))
    hostThread.start()
    scannerThread.start()

По крайней мере, это заставит вас запустить два ваших процесса вместе.Вам все еще нужно выяснить аспект управления потоками этого.

...