我有一个Pythonspark代码如下。它基本上从self.user_RDD中获取user_id并且对于那个user_id它结合了来自product_CF和的产品产品列表。然后保存到Redis中。foruser_idinself.user_RDD.collect():product_CF=self.getpreferredProducts(user_id)try:product_list=json.loads(redis_client.hget('user_products',user_id))#combine2listforproduct_idinproduct_list:ifpro

根据these，Python中的print不是线程安全的articles.后一篇文章中提供了Python3解决方法。如何在Python2.6中获得线程安全的print？ 最佳答案 有趣的问题——考虑到print语句中发生的所有事情，包括softspace属性的设置和检查，使其“线程安全”(意思是，实际上:一个正在打印的线程在打印换行符时只向另一个线程产生“标准输出的控制”，因此保证输出的每一整行都来自单个线程)有点挑战(通常的简单方法为了实际线程安全——委派一个单独的线程专门“拥有”和处理sys.stdout，通过Queue.Que

根据these，Python中的print不是线程安全的articles.后一篇文章中提供了Python3解决方法。如何在Python2.6中获得线程安全的print？ 最佳答案 有趣的问题——考虑到print语句中发生的所有事情，包括softspace属性的设置和检查，使其“线程安全”(意思是，实际上:一个正在打印的线程在打印换行符时只向另一个线程产生“标准输出的控制”，因此保证输出的每一整行都来自单个线程)有点挑战(通常的简单方法为了实际线程安全——委派一个单独的线程专门“拥有”和处理sys.stdout，通过Queue.Que