diff options
| author | Pjotr Prins | 2015-03-14 18:28:02 +0300 |
|---|---|---|
| committer | Pjotr Prins | 2015-03-14 18:28:02 +0300 |
| commit | 38cb5d5c0606481cbc34bd1a1187264d1fc1b085 (patch) | |
| tree | ab4c34387b7e748c4615c511ebdde2c91c68bfee /wqflask | |
| parent | 086ce413e270d2ed07a1a385f84e569e3a478a39 (diff) | |
| download | genenetwork2-38cb5d5c0606481cbc34bd1a1187264d1fc1b085.tar.gz | |
Threading: Sleep while waiting
Diffstat (limited to 'wqflask')
| -rw-r--r-- | wqflask/wqflask/my_pylmm/pyLMM/kinship.py | 1 |
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") |