2 
def threadSocket(Socket, port):
    '''
    Thread encargado de sotener comunicacion entre Socket cliente y
    el puerto serial asignado
    Mientras se mantenga activo el thread de recepcion se intentara leer del
    puerto serial y enviarlo al socket cliente
    Se asume que socket y port son objetos vaidos validos
    '''
    #Intenta abrir el puerto serial
    try:
        COM = serial.Serial(port-1)
    except:
        #Si esta en uso no se encuentra disponible, muestra error
        print 'Error: Puerto COM'+str(port)+' no disponible'
    else:
        #Al conectarse se crea el thread de recepcion
        print 'Conectado a puerto COM'+str(port)
        rxThread = threading.Thread(target=rxThreadDef,args=(Socket,COM))
        rxThread.start()
        dato = ''
        #Mientras el thread este activo
        while rxThread.isAlive():
            try:
                #Lee del puerto serial y envia a Socket cliente
                dato += COM.read()
                if parserCOMToSocket(dato):
                    Socket.send(dato)
                    dato=''
            except:
                break
        print "Puerto cerrado!"
        #Cierra puerto Serial
        COM.close()
    #Cierra Socket
    Socket.close()
    #print "Hilo terminado"
def rxThreadDef(Socket,COM):
    '''
    Thread (Hilo) encargado de recibir la informacion del Cliente
    y enviarla por medio del puerto serial
    Si se genera algun error se rompe el ciclo y termina el thread
    '''
    dato = ''
    while 1:
        try:
            d = Socket.recv(1024)
        except:
            break
        if d:
            dato += d
            if parserSocketToCOM(dato):
                COM.write(dato)
                print dato
                dato = ''
        else:
            break

def parserSocketToCOM(dato):
    return True

def parserCOMToSocket(dato):
    return True

嗨，我尝试在 Python 2.7 中使用套接字实现串行端口和 AIR 应用程序之间的桥接

当rxThread死时，socketThread将能够关闭套接字和串口，因为客户端套接字死了。但是脚本需要等待从串口读取数据才能全部关闭。

如果我尝试使用 a timeout=0，CPU 使用率会增加到 100%。如果我尝试使用timeout=Nonebut use COM.isWaiting()，我会遇到同样的问题（100% 的 CPU）

我怎么知道套接字是否以其他方式关闭？

4

1 回答 1

1

如果您需要从两个来源阅读，您可以愉快地使用select(). 在这种情况下，您将不需要线程。select阻塞直到一个或多个资源可用，然后返回一组可用资源，以便您可以对每个资源做出反应。请注意，它select适用于文件描述符，您可能需要将其置于非阻塞模式。

于 2013-01-06T10:49:27.387 回答