wassname/cachier
1
0
Fork 0
mirror of https://github.com/wassname/cachier.git synced 2026-09-09 11:19:08 +08:00
Code Issues Packages Projects Releases Wiki Activity

removed over-the-top threading

Browse Source
This commit is contained in:
Shay Palachy
2016-08-30 15:02:45 +03:00
parent 58bb8d5db8
commit ff01c88049
1 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
cachier/core.py
+7 -5
View File
@@ -414,9 +414,9 @@ def cachier(stale_after=None, next_time=False, pickle_reload=True,
# print('Calling decorated function and waiting')
core.mark_entry_being_calculated(key)
func_res = func(*args, **kwds)
_get_executor().submit(
core.set_entry, key, func_res)
# core.set_entry(key, func_res)
# _get_executor().submit(
# core.set_entry, key, func_res)
core.set_entry(key, func_res)
return func_res
# print('And it is fresh!')
return entry['value']
@@ -425,9 +425,11 @@ def cachier(stale_after=None, next_time=False, pickle_reload=True,
return core.wait_on_entry_calc(key)
# core.mark_entry_being_calculated(key)
# print('No entry found. Calling like a boss.')
_get_executor().submit(core.mark_entry_being_calculated, key)
core.mark_entry_being_calculated(key)
# _get_executor().submit(core.mark_entry_being_calculated, key)
func_res = func(*args, **kwds)
_get_executor().submit(core.set_entry, key, func_res)
core.set_entry(key, func_res)
# _get_executor().submit(core.set_entry, key, func_res)
return func_res
def clear_cache():