Changeset 6e5b2a7 in sasmodels

Timestamp:

Sep 30, 2016 5:31:12 AM (8 years ago)

Author:

ajj

Branches:

master, core_shell_microgels, costrafo411, magnetic_model, release_v0.94, release_v0.95, ticket-1257-vesicle-product, ticket_1156, ticket_1265_superball, ticket_822_more_unit_tests

Children:

2222134

Parents:

0bef47b

git-author:

Paul Kienzle <pkienzle@…> (09/30/16 05:31:12)

git-committer:

Andrew Jackson <andrew.jackson@…> (09/30/16 05:31:12)

Message:

ticket 363: Allow other processes to run during long computations (#9)

• Allow other processes to run during long computations

( erroneous branch: fixing the tests in pringle model and Revert "and fixing the tests in pringle model".

File:

• sasmodels/kernelcl.py (modified) (2 diffs)

sasmodels/kernelcl.py

@@ -54 +54 @@
 import warnings
 import logging
+import time
 
 import numpy as np  # type: ignore
@@ -557 +558 @@
         #call_details.show(values)
         # Call kernel and retrieve results
-        last_call = None
-        step = 100
+        wait_for = None
+        last_nap = time.clock()
+        step = 1000000//self.q_input.nq + 1
         for start in range(0, call_details.num_eval, step):
             stop = min(start + step, call_details.num_eval)
             #print("queuing",start,stop)
             args[1:3] = [np.int32(start), np.int32(stop)]
-            last_call = [kernel(self.queue, self.q_input.global_size,
-                                None, *args, wait_for=last_call)]
+            wait_for = [kernel(self.queue, self.q_input.global_size, None,
+                               *args, wait_for=wait_for)]
+            if stop < call_details.num_eval:
+                # Allow other processes to run
+                wait_for[0].wait()
+                current_time = time.clock()
+                if current_time - last_nap > 0.5:
+                    time.sleep(0.05)
+                    last_nap = current_time
         cl.enqueue_copy(self.queue, self.result, self.result_b)
         #print("result", self.result)