Python中哈希表的并发处理方法

import threading
import hashlib

class HashTable(object):
    def __init__(self):
        self.table = {}

    def put(self, key, value):
        self.table[key] = value

    def get(self, key):
        return self.table.get(key)

class WorkerThread(threading.Thread):
    def __init__(self, ht, key, value):
        threading.Thread.__init__(self)
        self.ht = ht
        self.key = key
        self.value = value

    def run(self):
        self.ht.put(self.key, self.value)

def main():
    ht = HashTable()
    # 分配任务到不同线程中
    t1 = WorkerThread(ht, hashlib.md5(b'pidancode.com').hexdigest(), 'hello')
    t2 = WorkerThread(ht, hashlib.md5(b'皮蛋编程').hexdigest(), 'world')
    t1.start()
    t2.start()
    t1.join()
    t2.join()
    # 获取哈希表中的值
    print(ht.get(hashlib.md5(b'pidancode.com').hexdigest()))
    print(ht.get(hashlib.md5(b'皮蛋编程').hexdigest()))

if __name__ == '__main__':
    main()