Skip to content

Commit d2b9ef8

Browse files
committed
added thread sync
1 parent 7f87ab3 commit d2b9ef8

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

app.py

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@
44
from flask_restful import reqparse, abort, Api, Resource
55
import json
66
import pyodbc
7-
import threading
7+
from threading import Lock
88

99
# Initialize Flask
1010
app = Flask(__name__)
@@ -21,9 +21,15 @@
2121
conn = pyodbc.connect(os.environ['SQLAZURECONNSTR_WWIF'])
2222
conn_list.append(conn)
2323

24+
lock = Lock()
25+
2426
def getConnection():
2527
global conn_index
28+
29+
lock.acquire()
2630
conn_index += 1
31+
lock.release()
32+
2733
if conn_index > 9:
2834
conn_index = 0
2935
return conn_list[conn_index]

0 commit comments

Comments
 (0)