pythonのsocket通信で受け取れない

Question

import socket
from sys import flags
import numpy
import threading
import cv2

BUFFER_SIZE = 4096*10

buf = b''
currentPort = 50001



def main(port):
    global buf
    while True:
        print(port)
        with socket.socket(socket.AF_INET, socket.SOCK_DGRAM) as s:
            while True:
                s.bind(("0.0.0.0",port))
                try:
                    data,address = s.recvfrom(BUFFER_SIZE)
                    if len(data) <= 0:
                        break
                    buf = buf + data
                finally:
                    s.close()
                narray=numpy.frombuffer(buf,dtype='uint8')
            img = cv2.imdecode(narray,1)
            cv2.imshow('Capture',img)

        if cv2.waitKey(100) & 0xFF == ord('q'):
            break
        buf = b''


with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
    s.bind(('0.0.0.0', 50000))
    s.listen()
    while True:
        (connection, client) = s.accept()
        try:
            print('Client connected', client)
            data = connection.recv(BUFFER_SIZE)
            if data == b"OpenPortRequest":
                threading.Thread(target=main,args=[currentPort]).start()
                connection.send(str(currentPort).encode())
                currentPort += 1
        finally:
            connection.close()

↑サーバー

import socket
import cv2
import time
cap = cv2.VideoCapture(0)
cap.set(cv2.CAP_PROP_FPS, 30)
cap.set(3,320)
cap.set(4,240)
BUFFER_SIZE = 4096

with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
    s.connect(('127.0.0.1', 50000))
    s.send(b"OpenPortRequest")
    port = s.recv(BUFFER_SIZE).decode()
    print(port)

time.sleep(10)

with socket.socket(socket.AF_INET, socket.SOCK_DGRAM) as s:
    while True:
        ret, frame = cap.read()
        if not ret:
            break
        jpegstring=cv2.imencode('.jpg', frame)[1].tobytes()

        s.sendto(jpegstring,("127.0.0.1",int(port)))

↑クライアント
サーバーにOpenPortRequestと送るとmain関数が非同期で実行されクライアントにポート番号が返され、クライアントがそのポートをつかいudpでwebカメラのデータを送信するプログラムです。
ですが同期的に実行するとうまくいくのですが、非同期にしたとたんうまくいきません。
エラー文は特になく、カメラのウィンドウが表示されないというかんじです
どこか悪い場所があったら指摘してください。
pythonのバージョン3.7です

Comments

[hide5stm]

どのようにして非同期にしたのか、同期版と非同期版のソースの情報
うまくいかない場合のエラー
OSやpythonのversion情報があると誰かが考えてくれると思います

[AbeTakashi]

「うまくいきません」はもっと明確にした方がいいですよ。

参考）
https://teratail.com/help/question-tips#questionTips3-4-1

[t_obara]

socketに関わらず、別スレッドでうまくUIを表示できていますか？スレッドとUI系は取り扱いに注意が必要となります。