cafe-grader-web

Location: cafe-grader-web/lib/assets/libs/_multiprocessing.js - annotation

Show More
Commit Description:
merge with algo and add brython files that were missing
Commit Description:
merge with algo and add brython files that were missing
References:
r584:056392c00e67 merge java
File last commit:
r584:056392c00e67 merge java
Show/Diff file:
Action:
lib/assets/libs/_multiprocessing.js | 242 lines | 6.6 KiB | application/javascript | JavascriptLexer |
History | Source | Raw | Download
admin
merge with algo and add brython files that were missing
 r584 // multiprocessing
var $module = (function($B){
var _b_ = $B.builtins
var $s=[]
for(var $b in _b_) $s.push('var ' + $b +'=_b_["'+$b+'"]')
eval($s.join(';'))
//for(var $py_builtin in _b_){eval("var "+$py_builtin+"=_b_[$py_builtin]")}
var $ProcessDict = {__class__:$B.$type,__name__:'Process'}
var $convert_args=function(args) {
var _list=[]
for(var i=0, _len_i = args.length; i < _len_i; i++) {
var _a=args[i]
if(isinstance(_a, str)){_list.push("'"+_a+"'")} else {_list.push(_a)}
}
return _list.join(',')
}
$ProcessDict.__mro__ = [$ProcessDict, _b_.object.$dict]
$ProcessDict.__str__=$ProcessDict.toString=$ProcessDict.__repr__=function(self){
return '<object Process>'
}
$ProcessDict.is_alive = function(self){return self.$alive}
$ProcessDict.join = function(self, timeout){
// need to block until process is complete
// could probably use a addEventListener to execute all existing code
// after this join statement
self.$worker.addEventListener('message', function (e) {
var data=e.data
if (data.stdout != '') { // output stdout from process
$B.stdout.write(data.stdout)
}
}, false);
}
$ProcessDict.run = function(self){
//fix me
}
$ProcessDict.start = function(self){
//var _args=[]
//for(var i=0; i < self.$args.length; i++) {
// var _a=self.$args[i]
// if(isinstance(_a, str)){_args.push("'"+_a+"'")} else {_args.push(_a)}
//}
self.$worker.postMessage({target: self.$target,
args: $convert_args(self.$args),
// kwargs: self.$kwargs
})
self.$worker.addEventListener('error', function(e) { throw e})
self.$alive=true
}
$ProcessDict.terminate = function(self){
self.$worker.terminate()
self.$alive=false
}
// variables
//name
//daemon
//pid
//exitcode
function Process(){
//arguments group=None, target=None, name=None, args=(), kwargs=()
var $ns=$B.args('Process',0,{},[],arguments,{},null,'kw')
var kw=$ns['kw']
var target=_b_.dict.$dict.get($ns['kw'],'target',None)
var args=_b_.dict.$dict.get($ns['kw'],'args',tuple())
var worker = new Worker('/src/web_workers/multiprocessing.js')
var res = {
__class__:$ProcessDict,
$worker: worker,
name: $ns['name'] || None,
$target: target+'',
$args: args,
//$kwargs: $ns['kw'],
$alive: false
}
return res
}
Process.__class__ = $B.$factory
Process.$dict = $ProcessDict
var $PoolDict = {__class__:$B.$type,__name__:'Pool'}
$PoolDict.__mro__ = [$PoolDict, _b_.object.$dict]
$PoolDict.__enter__ = function(self){}
$PoolDict.__exit__ = function(self){}
$PoolDict.__str__ = $PoolDict.toString = $PoolDict.__repr__=function(self){
return '<object Pool>'
}
$PoolDict.map = function(){
var $ns=$B.args('Pool.map', 3,
{self:null, func:null, fargs:null}, ['self', 'func', 'fargs'],
arguments,{},'args','kw')
var func=$ns['func']
var fargs=$ns['fargs']
var _results=[]
fargs=iter(fargs)
var _pos=0
console.log(self.$processes)
_workers=[]
for(var i=0; i < self.$processes; i++) {
_workers[i] = new Worker('/src/web_workers/multiprocessing.js')
var arg
try{arg=getattr(fargs, '__next__')()}
catch(err) {
if (err.__name__ != 'StopIteration') throw err
}
console.log(arg)
_workers[i].finished=false
_workers[i].postMessage({target: func+'', pos: _pos,
args: $convert_args([arg])})
_pos++
_workers[i].addEventListener('message', function(e) {
_results[e.data.pos]=e.data.result
if (_results.length == args.length) return _results
try {
arg=getattr(fargs, '__next__')()
e.currentTarget.postMessage({target: func+'', pos: _pos,
args: $convert_args([arg])})
_pos++
} catch(err) {
if (err.__name__ != 'StopIteration') throw err
this.finished=true
}
}, false);
}
}
$PoolDict.apply_async = function(){
var $ns=$B.$MakeArgs('apply_async', 3,
{self:null, func:null, fargs:null}, ['self', 'func', 'fargs'],
arguments,{},'args','kw')
var func=$ns['func']
var fargs=$ns['fargs']
fargs=iter(fargs)
async_result = {}
async_result.get=function(timeout){
console.log(results)
console.log(fargs)
return this.results}
async_result.results=[]
var _pos=0
_workers=[]
for(var i=0; i < self.$processes; i++) {
_workers[i] = new Worker('/src/web_workers/multiprocessing.js')
var arg
try{arg=getattr(fargs, '__next__')()}
catch(err) {
if (err.__name__ != 'StopIteration') throw err
}
//console.log(arg)
//_workers[i].finished=false
_workers[i].postMessage({target: func+'', pos: _pos,
args: $convert_args([arg])})
_pos++
_workers[i].addEventListener('message', function(e) {
async_result.results[e.data.pos]=e.data.result
//if (_results.length == args.length) return _results
try {
arg=getattr(fargs, '__next__')()
e.currentTarget.postMessage({target: func+'', pos: _pos,
args: $convert_args([arg])})
_pos++
} catch(err) {
if (err.__name__ != 'StopIteration') throw err
this.finished=true
}
}, false);
}
console.log("return", async_result)
return async_result
}
function Pool(){
console.log("pool")
console.log(arguments)
var $ns=$B.args('Pool',1,
{processes:null},['processes'],arguments,{},'args','kw')
//var kw=$ns['kw']
var processes=$ns['processes']
if (processes == None) {
// look to see if we have stored cpu_count in local storage
// maybe we should create a brython config file with settings,etc..??
// if not there use a tool such as Core Estimator to calculate number of cpu's
// http://eligrey.com/blog/post/cpu-core-estimation-with-javascript
}
console.log(processes)
var res = {
__class__:$PoolDict,
$processes:processes
}
return res
}
Pool.__class__ = $B.$factory
Pool.$dict = $PoolDict
return {Process:Process, Pool:Pool}
})(__BRYTHON__)