openstack/deb-python-taskflow
Code Issues Proposed changes

Merge "Add a delay before releasing the lock"

Browse Source
This commit is contained in:
Jenkins
2014-03-10 17:19:32 +00:00
committed by Gerrit Code Review
parent ae28f0ba4b 2b875590cf
commit 9ebe01fd55
1 changed files with 7 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
taskflow/tests/unit/test_utils_lock_utils.py
View File

@@ -23,6 +23,11 @@ from concurrent import futures
from taskflow import test from taskflow import test
from taskflow.utils import lock_utils from taskflow.utils import lock_utils
# NOTE(harlowja): Sleep a little so time.time() can not be the same (which will
# cause false positives when our overlap detection code runs). If there are
# real overlaps then they will still exist.
NAPPY_TIME = 0.05
def _find_overlaps(times, start, end): def _find_overlaps(times, start, end):
overlaps = 0 overlaps = 0
@@ -39,10 +44,12 @@ def _spawn_variation(readers, writers, max_workers=None):
def read_func(): def read_func():
with lock.read_lock(): with lock.read_lock():
start_stops.append(('r', time.time(), time.time())) start_stops.append(('r', time.time(), time.time()))
time.sleep(NAPPY_TIME)
def write_func(): def write_func():
with lock.write_lock(): with lock.write_lock():
start_stops.append(('w', time.time(), time.time())) start_stops.append(('w', time.time(), time.time()))
time.sleep(NAPPY_TIME)
if max_workers is None: if max_workers is None:
max_workers = max(0, readers) + max(0, writers) max_workers = max(0, readers) + max(0, writers)