graingert
diff --git a/‎samples/waiter_gevent.py
Copy file name to clipboard
+25Lines changed: 25 additions & 0 deletions b/‎samples/waiter_gevent.py
Copy file name to clipboard
+25Lines changed: 25 additions & 0 deletions
diff --git a/‎samples/waiter_meinheld.py
Copy file name to clipboard
+19Lines changed: 19 additions & 0 deletions b/‎samples/waiter_meinheld.py
Copy file name to clipboard
+19Lines changed: 19 additions & 0 deletions
@@ -0,0 +1,25 @@
+from __future__ import print_function
+"""Demo using Gevent with mysqlclient."""
+
+import gevent.hub
+import select
+import MySQLdb
+
+
+def gevent_waiter(fd, hub=gevent.hub.get_hub()):
+    hub.wait(hub.loop.io(fd, 1))
+
+
+def f(n):
+    conn = MySQLdb.connect(user='root', waiter=gevent_waiter)
+    cur = conn.cursor()
+    cur.execute("SELECT SLEEP(%s)", (n,))
+    cur.execute("SELECT 1+%s", (n,))
+    print(cur.fetchall()[0])
+
+
+gevent.spawn(f, 1)
+gevent.spawn(f, 2)
+gevent.spawn(f, 3)
+gevent.spawn(f, 4)
+gevent.sleep(5)
@@ -0,0 +1,19 @@
+import meinheld
+import MySQLdb
+
+
+def meinheld_waiter(fd):
+    meinheld.server.trampoline(fd, read=True, timeout=10)
+
+
+def app(env, start):
+    cont = b"Hello, World\n"
+    conn = MySQLdb.connect(user="root", waiter=meinheld_waiter)
+    cur = conn.cursor()
+    cur.execute("SELECT SLEEP(2)")
+    start(b"200 OK", [('Content-Type', 'text/plain'), ('Content-Length', str(len(cont)))])
+    return [cont]
+
+
+meinheld.server.listen(("0.0.0.0", 8080))
+meinheld.server.run(app)