python - 多线程访问python字典

Question

我试图同时从 python 中的不同线程访问相同的全局字典。访问点的线程安全对我来说不是一个问题，因为所有访问都是读取并且不会修改字典。我更改了代码以从多个线程进行访问，但我注意到执行速度没有增加，在检查后似乎解释器实际上序列化了访问，从而使我的代码中的更改为空。

有没有一种简单的方法可以在Python中拥有像Java的concurrentHashMap这样的结构？有问题的代码部分如下:

    class csvThread (threading.Thread):
        def __init__(self, threadID, bizName):
            threading.Thread.__init__(self)
            self.threadID = threadID
            self.bizName = bizName
        def run(self):
            thread_function(self.bizName)



    def thread_function(biz):
        first = True
        bizTempImgMap = {}
        for imag in bizMap[biz]:
            if not similar(bizTempImgMap, imgMap[imag]):
                bizTempImgMap[imag] = imgMap[imag]
                if first:
                    a = imgMap[imag]
                    sum = a
                else:
                    c = np.column_stack((a, imgMap[imag]))
                    sum += imgMap[imag]
                    a = c.max(1) #max
                first = False
            else:
                print ("-")
        csvLock.acquire()
        writer.writerow([biz]+a.astype(np.str_).tolist()+(np.true_divide(sum, len(bizTempImgMap.keys()))).tolist())
        csvLock.release()


csvLock = threading.Lock()
...
imgMap = img_vector_load('test_photos.csv')
bizMap = img_busyness_load('csv/test_photo_to_biz_ids.csv')
...
for biz in bizMap.keys():
    if len(threads)<100:
        thread = csvThread(len(threads), biz)
        threads.append(thread)
        thread.start()
    else:
        print("\nWaiting for threads to finish\n")
        for t in threads:
            t.join()
        print("\nThreads Finished\n")
        threads = []

Answer 1

"i have noticed no increase in the speed of the execution"

在 python 中使用线程不会提高速度，因为它们都在同一个核心上工作。查看:GIL

请注意，Python 线程应该用于并发架构，而不是速度性能。

如果您想保留此实现，请使用 multiprocessing .