5

Python プログラムを使用していますが、アプリケーションを で終了すると Ctrl-c、スクリプトが閉じません。私のプロセスはまだ実行中のプロセスに表示されます。

#!/usr/bin/env python
import socket
import threading
import Queue
import serial
import mysql.connector
from datetime import datetime, date, time


host = '0.0.0.0'
port = 1024
buffer = 102400
my_queue = Queue.Queue()

class readFromUDPSocket(threading.Thread):

    def __init__(self, my_queue): 
        threading.Thread.__init__(self)
        self.my_queue = my_queue

    def run(self):
        while True:
            buffer1,addr = socketUDP.recvfrom(buffer)
            self.my_queue.put(buffer1)
            print 'UDP received'

class readFromSerial(threading.Thread):

    def __init__(self, my_queue): 
        threading.Thread.__init__(self)
        self.my_queue = my_queue


    def run(self):
        while True:
            buffer2 =  ser.readline(eol=';')
            if buffer2:
                self.my_queue.put(buffer2)
                print 'Serial received'

class process(threading.Thread):

    def __init__(self, my_queue):
        threading.Thread.__init__(self)
        self.my_queue = my_queue
        self.alive = threading.Event()
        self.alive.set()

    def run(self):
        while True: 
            buffer3 = self.my_queue.get()
            today = datetime.now()
            timestamp = today.strftime("%A, %B %d, %Y %H:%M:%S")
            print 'Data pushed at:', timestamp
            print buffer3
            if buffer3.startswith('temp:'):
                temp = buffer3.replace('temp:','')
                cnx = mysql.connector.connect(user='root', password='xxxxx', database='temperature')
                cursor = cnx.cursor()
                cursor.execute("INSERT INTO temperature.temperature (time,temperature) VALUES (%s, %s)", [timestamp, temp])
                print 'Data inserted into Database'
                cnx.commit()
                cursor.close()
                cnx.close()


if __name__ == '__main__':

    # Create socket (IPv4 protocol, datagram (UDP)) and bind to address
    socketUDP = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    socketUDP.bind((host, port))
    ser = serial.Serial('/dev/ttyUSB0', 57600, timeout=2)


    # Instantiate & start threads
    myServer = readFromUDPSocket(my_queue)
    mySerial = readFromSerial(my_queue)
    myDisplay = process(my_queue)

    myServer.start()
    myDisplay.start()
    mySerial.start()

while 1:
    pass

UDPSock.close()
ser.close()

Python スレッドが で閉じないのはなぜCtrl+cですか?

4

3 に答える 3

8

スレッドをデーモンスレッドにする必要があります。これを行うには、スレッドの init を呼び出した後に次の行を追加します

self.setDaemon(True)

デーモンスレッドだけが生き残ったときにプログラムは終了します。メインスレッドはもちろん非デーモンです

于 2012-09-19T11:07:56.457 に答える
3

the_thread.setDaemon(true)、 http://docs.python.org/library/threading.html#threading.Thread.daemonを参照してください。

于 2012-09-19T11:09:23.870 に答える
0

コマンドでshell=Trueオプションを設定したため、python サブプロセスを強制終了できませんでした。process.Popenshell=True を削除すると、それを強制終了できました。

サブプロセスがシェルの場合、シェルが終了する前に実行中のものを強制終了する必要があります。

于 2014-01-12T17:03:41.420 に答える