threaded test of read/write to marker cache
This commit is contained in:
parent
8abda7c7ae
commit
a50051bded
1 changed files with 10 additions and 0 deletions
|
@ -5,6 +5,7 @@ import os
|
||||||
from utilities import execution_path
|
from utilities import execution_path
|
||||||
from nose.tools import *
|
from nose.tools import *
|
||||||
import mapnik
|
import mapnik
|
||||||
|
import threading
|
||||||
|
|
||||||
def setup():
|
def setup():
|
||||||
# All of the paths used are relative, if we run the tests
|
# All of the paths used are relative, if we run the tests
|
||||||
|
@ -101,6 +102,15 @@ def test_image_put_and_clear_marker_cache():
|
||||||
eq_(image_file in cache.keys(),False)
|
eq_(image_file in cache.keys(),False)
|
||||||
eq_(cache.size(),3)
|
eq_(cache.size(),3)
|
||||||
|
|
||||||
|
def test_threaded_reads_and_writes():
|
||||||
|
threads = []
|
||||||
|
for i in range(100):
|
||||||
|
t = threading.Thread(target=test_image_put_and_clear_marker_cache)
|
||||||
|
t.start()
|
||||||
|
threads.append(t)
|
||||||
|
for t in threads:
|
||||||
|
t.join()
|
||||||
|
|
||||||
if __name__ == "__main__":
|
if __name__ == "__main__":
|
||||||
setup()
|
setup()
|
||||||
[eval(run)() for run in dir() if 'test_' in run]
|
[eval(run)() for run in dir() if 'test_' in run]
|
||||||
|
|
Loading…
Add table
Reference in a new issue