diff options
| author | Ian Johnson <ian.johnson@appliedlanguage.com> | 2013-06-10 19:47:12 +0400 |
|---|---|---|
| committer | Ian Johnson <ian.johnson@appliedlanguage.com> | 2013-06-10 19:47:12 +0400 |
| commit | 210265b6f4dd39d5c256fe27c1c4fe815d83a7a7 (patch) | |
| tree | 1efd73ff4a2794abf439e80463bd696ddc8679a2 /examples | |
| parent | 0d0d652c0520d85bded7d44377a771339b8bb9fa (diff) | |
PCLc: Slight optimisation in parallel component code generation, and instrumented components in code generation. PCL-Run: Bigger default thread pool. Also, updated Pypeline.
Diffstat (limited to 'examples')
| -rw-r--r-- | examples/conditional/conditional.cfg | 2 | ||||
| -rw-r--r-- | examples/parallel_sleep/parallel_sleep.cfg | 2 | ||||
| -rw-r--r-- | examples/parallel_sleep/sleep.py | 5 |
3 files changed, 5 insertions, 4 deletions
diff --git a/examples/conditional/conditional.cfg b/examples/conditional/conditional.cfg index a033b2c..5a7b484 100644 --- a/examples/conditional/conditional.cfg +++ b/examples/conditional/conditional.cfg @@ -2,6 +2,6 @@ f = False [Inputs] -a = True +a = False b = then c = else diff --git a/examples/parallel_sleep/parallel_sleep.cfg b/examples/parallel_sleep/parallel_sleep.cfg index 890a70c..b5b4ab6 100644 --- a/examples/parallel_sleep/parallel_sleep.cfg +++ b/examples/parallel_sleep/parallel_sleep.cfg @@ -2,4 +2,4 @@ sleep_command = /bin/sleep [Inputs] -sleep_time = 60 +sleep_time = 5 diff --git a/examples/parallel_sleep/sleep.py b/examples/parallel_sleep/sleep.py index 35c7be7..e6ae72c 100644 --- a/examples/parallel_sleep/sleep.py +++ b/examples/parallel_sleep/sleep.py @@ -16,7 +16,7 @@ # You should have received a copy of the GNU General Public License # along with Pipeline Creation Language (PCL). If not, see <http://www.gnu.org/licenses/>. # -import os +import subprocess def get_name(): return "sleep" @@ -35,7 +35,8 @@ def configure(args): def initialise(config): def sleep_function(a, s): - os.system(" ".join([config['sleep_command'], str(a['sleep_time'])])) + proc = subprocess.Popen([config['sleep_command'], str(a['sleep_time'])]) + proc.communicate() return {'complete' : True} return sleep_function |