-
-
Save zorkian/824e86d0d7f001965f62dc8ae7ad28db to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
# | |
# Demonstrate fdb blocking main thread when the network thread is started. | |
# | |
import time | |
import gevent | |
import gevent.monkey | |
gevent.monkey.patch_all() # Works if: (thread=False) | |
import fdb | |
fdb.api_version(510) | |
DB = None | |
@fdb.transactional | |
def write_time(tr): | |
tr['now'] = bytes(time.time()) | |
@fdb.transactional | |
def read_time(tr): | |
return tr['now'] | |
def get_db(): | |
global DB | |
if DB is not None: | |
return DB | |
# Doesn't matter whether we use event_model="gevent" or None | |
DB = fdb.open(event_model="gevent") | |
return DB | |
def writer(): | |
while True: | |
print 'Writer!' | |
write_time(get_db()) | |
time.sleep(1) | |
def reader(): | |
while True: | |
print 'Reader!' | |
time.sleep(1) | |
print read_time(get_db()) | |
gevent.spawn(writer) | |
gevent.spawn(reader) | |
gevent.sleep(5) |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Expected output:
When network thread blocks main thread, output is: