File: InitQueue.m

package info (click to toggle)
openems 0.0.35+dfsg.1-3
  • links: PTS, VCS
  • area: main
  • in suites: buster
  • size: 6,288 kB
  • sloc: cpp: 40,259; yacc: 580; lex: 350; makefile: 258; sh: 169; ruby: 19
file content (90 lines) | stat: -rw-r--r-- 2,629 bytes parent folder | download | duplicates (2)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
function [queue] = InitQueue(varargin)
% function [queue] = InitQueue(varargin)
%
% Use this function to initialize a queue to run one or more matlab scripts
% in parallel.
% This can be used to efficiently run an openEMS parameter sweep in parallel
% on multiple remote machines.
%
% Options:
%   DependPath: Add multiple paths, your script may depend on
%   UseOctave:  Enable/Disable octave usage
%   MaxThreads: max. number of parallel executions
%
% Note:
%   - Currently only Linux/Unix is supported
%   - By default Octave is used to spawn parallel functions (saves
%       licenses), but this can be changed by:
%       [queue] = InitQueue('UseOctave', 0);
%       You may need to change this, if your script is not octave compatible
%   - To efficiently run openEMS in parallel, you need to run it on several
%   machines using a SSH.host_list setting --> See also RunOpenEMS
%
% Example:
%   %serial version:
%   for n=1:10
%       % manipulate parameter etc.
%       [result1(n) result2(n)] = Parallel_Func_Name(param1, param2);
%   end
%
%   %parallel version:
%   queue = InitQueue('DependPath',{'/opt/openEMS/CSXCAD/matlab', ...
%                                   '/opt/openEMS/openEMS/matlab'});
%   for n=1:10
%       % manipulate parameter etc.
%       queue = Add2Queue(queue, 'Parallel_Func_Name', {param1, param2});
%   end
%
%   % wait for all to finish
%   [queue] = FinishQueue(queue);
%
%   % retrieve result
%   for n=1:numel(stub_sweep)
%     [result1(n) result2(n)] = ResultsQueue(queue,n);
%   end
%
% See also: Add2Queue, FinishQueue, ResultsQueue, RunOpenEMS,
%           RunOpenEMS_Parallel, FindFreeSSH
%
% openEMS matlab interface
% -----------------------
% author: Thorsten Liebig

if ~isunix
    error 'your OS is not supported (Unix only)'
end

queue.use_octave = exist('OCTAVE_VERSION','builtin') ~= 0;

queue.verbose = 1;

queue.maxThreads = Inf;

% add current path
queue.DependPath = ['addpath(''' pwd ''');'];

for n=1:2:nargin
    if strcmp(varargin{n},'DependPath');
        for m=1:numel(varargin{n+1})
            queue.DependPath = [queue.DependPath 'addpath(''' varargin{n+1}{m} ''');'];
        end
    end
    if strcmp(varargin{n},'UseOctave');
        queue.use_octave = varargin{n+1};
    end
    if strcmp(varargin{n},'MaxThreads');
        queue.maxThreads = varargin{n+1};
    end
end


% set binaries and options
if (queue.use_octave)
    queue.bin = ['export LD_LIBRARY_PATH=""; octave'];
    queue.bin_options = [' --silent --eval'];
else
    queue.bin = [matlabroot '/bin/matlab'];
    queue.bin_options = [' -nodesktop -nosplash  -r'];
end

queue.jobs_finished = [];