python
import pickle
import threading
from pickledb import PickleDB
lock = threading.Lock()
db = PickleDB('data.db', False)
def write_to_db(key, value):
with lock:
db.dset(key, value)
def read_from_db(key):
with lock:
return db.dget(key)
python
import pickle
import threading
from pickledb import PickleDB
local_data = threading.local()
db = PickleDB('data.db', False)
def write_to_db(key, value):
if not hasattr(local_data, 'lock'):
local_data.lock = threading.Lock()
with local_data.lock:
db.dset(key, value)
def read_from_db(key):
if not hasattr(local_data, 'lock'):
local_data.lock = threading.Lock()
with local_data.lock:
return db.dget(key)
python
db = PickleDB('data.db', False, True)