Python线程:哪些函数在哪个线程中运行

问题描述 投票:0回答:1

因此,我有一个pyhthon应用程序,我正在尝试模拟队列排队系统。它导入一个库并调用该库,特别是psycopg2。示例代码如下

import threading,queue,psycopg2

q = queue.Queue()

def workerChecker():
  while True:#Keeps the thread always checking for new things in queue
    item = q.get()
    addItemToDb(item) <------This part 
    q.task_done()

threading.Thread(target=workerChecker, daemon=True).start()

def addItemToDb(item):
  #Do something and use psycopg2 to insert item to db here

所以我似乎无法在线找到一个明确的答案,addItemToDb中的代码将在哪个线程上运行。

[更具体地说,将addItemToDb函数中的所有代码限制为与workerChecker在同一线程中执行吗?鉴于它使用导入的库。

任何帮助或帮助将不胜感激...

python multithreading psycopg2 race-condition
1个回答
0
投票

addItemToDb中的代码将被限制为运行workerChecker的线程,只要它仅由该函数调用即可,但是它可以在主线程或您创建的任何其他线程之外的任何地方使用。

如果要确保只有workerChecker可以访问该功能,可以在addItemToDb中定义workerChecker

def workerChecker():
    def addItemToDb(item):
        # addItemToDb definition
        pass
    while True:
        item = q.get()
        addItemToDb(item)
        q.task_done()
© www.soinside.com 2019 - 2024. All rights reserved.