丢盒子: 应该怎么准备multi-thread?

我看丢盒子很喜欢问multi-thread的题. 我工作一般都没写过. 应该怎么准备multi-thread? Java还是python好? 都用什么framework?

1. class KVStore(object):
   
2. 
   
3.     def __init__(self):
   
4.         """Initializes the key-value store."""
   
5.         # type: () -> None
   
6.         self.txid = 0
   
7.         self.actual_data = {}
   
8.         self.tx_data = defaultdict()
   
9. 
   
10.     def begin(self):
    
11.         """Starts a transaction, returns a txid."""
    
12.         # type: () -> int
    
13.         self.txid += 1
    
14.         return self.txid
    
15. 
    
16.     def read(self, txid, key):
    
17.         """Reads a value given a key, within the context of a transaction."""
    
18.         # type: (int, Text) -> Optional[int]
    
19.         # if txid in self.tx_data:
    
20.         val_list = self.tx_data.get(key)
    
21.         if not val_list:
    
22.             return self.actual_data.get(key)
    
23. 
    
24.         if len(val_list) == 1:
    
25.             return val_list[0][0]
    
26.         else:
    
27.             raise Exception("value is written by multi tx")
    
28. 
    
29.     def write(self, txid, key, val):
    
30.         """Writes a value to a key within the context of a transaction."""
    
31.         # type: (int, Text, int) -> None
    
32.         # if key in self.actual_data:
    
33.         #     del self.actual_data[key]
    
34. 
    
35.         if key in self.tx_data:
    
36.             if txid != self.tx_data[key][0][1]:
    
37.                 raise Exception("value is written by another txid")
    
38.             Else:
    
39.                 self.tx_data[key] = list()
    
40. 
    
41.         self.tx_data[key].append((val, txid))
    
42. 
    
43.     def commit(self, txid):
    
44.         """Commits writes to the store. The transaction may no longer be used."""
    
45.         # type: (int) -> None
    
46.         for key, val_list in self.tx_data.items():
    
47.             # if not conflict
    
48.             for val, version in val_list:
    
49.                 if version == txid:
    
50.                     self.actual_data[key] = val
    
51.                 val_list.remove((val, version))

复制代码

当时考了一个分布式下的kv store读写操作，主要是考虑事务一致性 比如用户a 修改了key abc 但还没有commit 这时候用户b也读取了key abc 实现read serialible

Chasedream.df 发表于 2022-7-3 13:05
当时考了一个分布式下的kv store读写操作，主要是考虑事务一致性 比如用户a 修改了key abc 但还没有commit  ...

是System Design还是Coding?

CCCC1233 发表于 2022-07-03 10:12:07
是System Design还是Coding?

coding

同問 推一下