aboutsummaryrefslogtreecommitdiff
path: root/wqflask
diff options
context:
space:
mode:
authorPjotr Prins2015-03-14 18:28:02 +0300
committerPjotr Prins2015-03-14 18:28:02 +0300
commit38cb5d5c0606481cbc34bd1a1187264d1fc1b085 (patch)
treeab4c34387b7e748c4615c511ebdde2c91c68bfee /wqflask
parent086ce413e270d2ed07a1a385f84e569e3a478a39 (diff)
downloadgenenetwork2-38cb5d5c0606481cbc34bd1a1187264d1fc1b085.tar.gz
Threading: Sleep while waiting
Diffstat (limited to 'wqflask')
-rw-r--r--wqflask/wqflask/my_pylmm/pyLMM/kinship.py1
1 files changed, 1 insertions, 0 deletions
diff --git a/wqflask/wqflask/my_pylmm/pyLMM/kinship.py b/wqflask/wqflask/my_pylmm/pyLMM/kinship.py
index 1383c782..9ab48510 100644
--- a/wqflask/wqflask/my_pylmm/pyLMM/kinship.py
+++ b/wqflask/wqflask/my_pylmm/pyLMM/kinship.py
@@ -119,6 +119,7 @@ def kinship(G,options):
results.append(p.apply_async(compute_matrixMult, (job,W)))
# Do we have a result?
while (len(results)-completed>cpu_num*2):
+ time.sleep(0.1)
try:
j,x = q.get_nowait()
if options.verbose: sys.stderr.write("Job "+str(j)+" finished\n")