我编写了一个函数collect_data,它使用4个线程从4个网站(例如,网站a至d)收集数据,并在mysql表中进行简单的更新;在表中,有4个字段,每个字段存储来自一个网站的数据,在更新该表时使用无锁。这4个线程每10秒在mysql中收集数据和更新数据。
def collect_data(site_list = ['a', 'b', 'c', 'd']):
for site in site_list:
InfoCollectingThread(site).start()不幸的是,在运行了一段时间(比如3个小时)之后,mysql中没有新的记录。另外,由于没有提前更新相应的字段,一些线程似乎会提前死亡。
我的问题是,在我的设计过程和任何解决方案中存在什么问题?圣诞快乐。
发布于 2014-12-25 08:19:50
有太多的可能原因和太少的信息让我们作出知情的猜测。我可以为您提供一些关于如何解决此问题的建议:
try-finally部分),并带有调试输出。这样,如果一根线死了,你就会知道。https://stackoverflow.com/questions/27645295
复制相似问题