python - 多线程时循环不使用新变量运行

Question

我目前正在做我最后一年的大学项目，我陷入了我认为的线程问题。我希望能够多次运行我的方法，但每次运行时都应该用新值更新变量。我正在查询 API 以获取 userID，然后通过将其设置为全局变量将其传递到我的 main 方法中。

def setup():


    try:
        global gun_cascade, camera, frameRate, property_id, length, firstFrame, framecount,i,increment,start_Time,end_Time,statusCopy,userID

        gun_cascade = cv2.CascadeClassifier('cascade.xml')
        camera = cv2.VideoCapture('gun.mp4')
        if camera.isOpened() == False:
            print("Can't open video, isOpened is empty exiting now.")
            exit(0)
        frameRate = camera.get(5)
        property_id = int(cv2.CAP_PROP_FRAME_COUNT)
        length = int(cv2.VideoCapture.get(camera, property_id))

        firstFrame = None
        count = 0
        gun_exist = False
        increment = 0
        start_Time = 0
        end_Time = 0
        i = 0


    except Exception as e:
        print(e)
        exit(0)

上面我将 userID 设置为全局

def decision():
    setup()
    user_object = listener.userIdListner()
    tokenId = user_object.token

    status = user_object.status
    if user_object.status == "ON":
        #status=statusCopy[:]
        #aux = copy.deepcopy(matriz)
        global statusCopy

        statusCopy = copy.deepcopy(tokenId)
        print("About to run mainscrt"+statusCopy)
        #print(type(userID))
        print(type(user_object))

        post_object = listener.mainNullPostMethod()
        post_object.null
        print(post_object.null)
        #opening a a new thread
        Thread(target = main).start()
        #post_object = listener.mainNullPostMethod()
        #post_object.null
        #print(post_object.null)


    else:
        print ("Program failed to run")

在这里，我查询 API 以获取 userId 以及打开或关闭的状态。目前运行良好。但问题是，如果这个方法正在运行，并且想要使用新的 userID 再次运行它，它会一直工作，直到 'whilecamera.isOpened():' 当我到达这一点时，我没有得到任何错误或任何东西

def main():


    #printing out the userid to see if it's been changed
    userID = statusCopy
    print("The current userID is "+userID)

    while isOpened:


        framecount =0
        framecount += 1
        frameId = camera.get(1) #current frame number

        (grabbed, frame) = camera.read()
        if not grabbed:
            break

        # resize the frame, convert it to grayscale, and blur it
        frame = imutils.resize(frame, width=500)
        gray = cv2.cvtColor(frame, cv2.COLOR_BGR2GRAY)
        #gray = cv2.GaussianBlur(gray, (21, 21), 0)

        #gray = cv2.dilate(gray, None, iterations=2)

        #stuff to try in the future
        #scaleFactor=1.1, minNeighbors=5, minSize=(30, 30), flags=cv2.CASCADE_SCALE_IMAGE, outputRejectLevels = True
        gun = gun_cascade.detectMultiScale(gray, 3,5)

        for (x,y,w,h) in gun:
            randID = uuid.uuid4().hex
            frame = cv2.rectangle(frame,(x,y),(x+w,y+h),(255,0,0),2)

            roi_gray = gray[y:y+h, x:x+w]
            roi_color = frame[y:y+h, x:x+w]
            rects = gun[0]
            neighbours = gun[0]
            weights = gun[0]
           if (frameId % math.floor(frameRate) == 1):
                cv2.putText(frame, datetime.datetime.now().strftime("%A %d %B %Y %I:%M:%S%p"),(10, frame.shape[0] - 10), cv2.FONT_HERSHEY_SIMPLEX, 0.35, (255, 165, 0), 1)
                cv2.imwrite('bin/' + userID+'-'+randID + '.jpg', frame)
                if userID == "NULL":
                    print("failed due to user null")
                    break
                print("working on pushing images to s3"+userID)
                s3.uploadDirectory("bin/", "open-gun-recordings",userID)

                picURL = "s3bucket.com/users/screenshots/"+userID+'/'+userID+'-'+randID+'.jpg'

                text.fire(picURL)



        cv2.imshow("Security Feed", frame)
        key = cv2.waitKey(1) & 0xFF


    camera.release()
    cv2.destroyAllWindows()

上面我希望能够同时运行此方法的多个实例，并且每个实例都有不同的 userId。

if __name__ == '__main__':
    #mainNullPostMethod()
    #runDecision()
    while True:

        time.sleep(5)
        decision()

任何帮助和建议将不胜感激。我不是 python 方面最好的人，所以如果这是一个愚蠢的问题，我深表歉意

Answer 1

首先不要使用全局变量，它们很糟糕，因为从多个函数(在您的情况下是多个线程)进行更改时，这使得跟踪变得困难 as described in this answer 。

我看到的问题是在用于生成线程的 main 函数中初始化 userID ，问题是即使您初始化 userID =在 main 中的 statusCopy ，即使您在 decision 中使用 statusCopy = copy.deepcopy(tokenId) 进行深度复制，它仍然会是被任何并发决策调用全局覆盖。

让我们想象一下，您第一次调用 decision，初始化 userID，然后为 main 生成一个线程，该线程使用该userID。现在我不确定 main 执行需要多长时间，但为了论证，我们假设您使用 sleep 等待 5 秒，然后执行整个事情再次发生(当第一个线程仍在运行时)。现在，您基本上通过第二次执行整个函数链来更改 userID ，并且第一个线程开始使用修改后的 userID ，根据定义，这已经是不好的做法，因为您想要在您的第一个线程中使用特定的userID信息。我建议您将深度复制传递给线程，并在 main 中初始化本地 userID，这样它就不会被并发线程更改。

此外，我不确定您是否想要执行 while True 并每 5 秒生成一次线程，也许您也应该在那里设置限制。