Python 线程挂起并且不关闭

标签 python multithreading

这是我第一次尝试在 Python 中使用线程, 我写了下面的程序作为一个非常简单的例子。它只是获取一个列表并使用一些线程打印它。但是,每当出现错误时,程序就会在 Ubuntu 中挂起,我似乎无法做任何事情来恢复控制提示,所以必须重新启动另一个 SSH session 才能重新进入。 也不知道我的程序有什么问题。 我可以放入某种错误处理以确保它不会挂起。 另外,知道为什么 ctrl/c 不起作用(我没有中断键)

from Queue import Queue
from threading import Thread
import HAInstances
import logging

log = logging.getLogger()
logging.basicConfig()

class GetHAInstances:
    def oraHAInstanceData(self):
        log.info('Getting HA instance routing data')
        # HAData = SolrGetHAInstances.TalkToOracle.main()   
        HAData = HAInstances.main()
        log.info('Query fetched ' + str(len(HAData)) + ' HA Instances to query')
        # for row in HAData:
        # print row
        return(HAData)

def do_stuff(q):
  while True:
    print q.get()
    print threading.current_thread().name
    q.task_done()


oraHAInstances = GetHAInstances()
mainHAData = oraHAInstances.oraHAInstanceData()

q = Queue(maxsize=0)
num_threads = 10

for i in range(num_threads):
    worker = Thread(target=do_stuff, args=(q,))
    worker.setDaemon(True)
    worker.start()

for row in mainHAData:
    #print str(row[0]) + ':' +  str(row[1]) + ':' + str(row[2]) + ':' + str(row[3])i
    q.put((row[0],row[1],row[2],row[3]))

q.join()

最佳答案

在你的线程方法中,推荐使用“try ... except ... finally”。这种结构保证即使在发生错误时也能将控制权返回给主线程。

def do_stuff(q):
    while True:
        try:
            #do your works
        except:
            #log the error
        finally:
            q.task_done()

此外,如果您想终止程序,请找出主线程的 pid 并使用 kill #pid 终止它。在 Ubuntu 或 Mint 中,使用 ps -Ao pid,cmd,在输出中,您可以通过搜索您自己键入的运行 Python 的命令(第二列)来找出 pid(第一列)脚本。

关于Python 线程挂起并且不关闭,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/25604816/

相关文章:

c - 为什么更多的线程需要更多的时间来处理?

Python ThreadPoolExecutor - 是否保证回调与提交的函数在同一线程中运行?

c++ - concurrent_vector 无效数据

multithreading - 关于线程的内存资源的重新分配

python - 使用 setuptools 通过 Python 库安装的数据文件位置

python - 按列中特定月份的日期对 Pandas 数据框进行子集化?

python - 没有模型和数据库的Django元素

java - 我该如何做才能让方法等待执行器运行?

python - 在 Python 中动态导入文件

Python - 比较两个列表以匹配项目包含不等于的项目?