y69-yamv/iter.js at master · nicklem/y69-yamv · GitHub

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
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
/*
 ************************
 ** By                 **
 ** Nicola Klemenc     **
 ** github.com/nicklem **
 ************************
 */

var ITER = ( function() {

  var mThreadData = [] ;
  var getThreadData = function() { return mThreadData ; } ;
  // var flushThreadData = function() { mThreadData = [] ; } ;
  var resetThreadData = function() {
    mThreadData = [] ;
    if( isSingleThread() ) mThreadData.push( [] ) ;
  } ;

  var $mBrotWorkers = [] ;
  var setWorker = function( workerID ) {
    $mBrotWorkers[ workerID ] = new Worker( "threadcalc.js" ) ;
    $mBrotWorkers[ workerID ].onmessage = onWorkerDone ;
  } ;
  var onWorkerDone = function( e ) {
    var workerID = e.data[ 0 ] , threadData = e.data[ 1 ] ;
    mThreadData[ workerID ] = Uint8Array.from( threadData ) ;
    incThreadDone() ;
    if( allThreadsDone() ) { redrawAndReset() }
  } ;
  var isWorkerUndefined = function( workerID ) { return typeof $mBrotWorkers[ workerID] === "undefined" ; } ;

  var threadsDone = 0 ;
  var incThreadDone = function() { threadsDone += 1 ; } ;
  var allThreadsDone = function() { return threadsDone === OPT.getOptionData().multiThread.options[ OPT.getOptionData().multiThread.value ] ; } ;
  var resetThreadDone = function() { threadsDone = 0 ; } ;

  var initCalc = function() {
    resetThreadData() ;
    PLANE.setRotBounds() ;
    PLANE.setPToCArrays() ;
  } ;

  var execCalc = function() {
    execThreads() ;
    return this ;
  } ;

  var execThreads = function() {
    var yPixWidth = PLANE.getYPixWidth() ;
    var numThreads = OPT.getNumThreads() ;
    var yPixPerThread = Math.floor( yPixWidth / numThreads ) ;
    var yStart , yEnd , isLastThread ;
    for( var workerID = 0 ; workerID < numThreads  ; workerID++ ) {
      yStart = workerID * yPixPerThread ;
      yEnd = yStart + yPixPerThread ;
      startWorker( workerID , yStart , yEnd ) ;
    }
  } ;

  var startWorker = function( workerID , yStart , yEnd ) {
    if( isWorkerUndefined( workerID ) ) { setWorker( workerID ) ; }
    // TODO: improve performance timing
    // TODO: stop extra threads when lowering count
    startTimer() ;
    var xC = PLANE.getXPixWidth();
    var yC = PLANE.getYPixWidth() ;
    $mBrotWorkers[ workerID ].postMessage( {
      "iterVal"            : OPT.getOptionData().iter.value ,
      "maxSq"              : OPT.getMaxSq() ,
      "rotationAngle"      : MATH.toRad( OPT.getRot() ) ,
      "toReZ"              : PLANE.getToReZ() ,
      "toImZ"              : PLANE.getToImZ() ,
      "xRotBoundOffset"    : PLANE.getXRotBoundOffset() ,
      "yRotBoundOffset"    : PLANE.getYRotBoundOffset() ,
      "xOriginRotOffset"   : MATH.xRotOffset( xC/2 , yC/2 , MATH.toRad( OPT.getRot() ) ) ,
      "yOriginRotOffset"   : MATH.yRotOffset( xC/2 , yC/2 , MATH.toRad( OPT.getRot() ) ) ,
      "yStart"             : yStart ,
      "yEnd"               : yEnd ,
      "xWidth"             : xC ,
      "workerID"           : workerID ,
      "isPolar"            : OPT.isPolar() ,
    } ) ;
  } ;

  var redrawAndReset = function() {
    CANVAS.redraw() ;
    UTIL.consoleLog( OPT.getNumThreads() + "T/x" + PLANE.getOverallZoom().toPrecision( 3 ) , Math.round( performance.now() - window.$mBrotPerfStart ) + " ms" ) ;
    resetThreadDone() ;
  } ;

  var hasWorkers = function() { return !! window.Worker ; } ;
  var isMultiThread = function() { return OPT.getOptionData().multiThread.value !== "One" } ;
  var isSingleThread = function() { return OPT.getOptionData().multiThread.value === "One" } ;
  var maxThreads = function() { return !! navigator.hardwareConcurrency ? navigator.hardwareConcurrency : 1 ; } ;
  var startTimer = function() { window.$mBrotPerfStart = performance.now() ; } ;

  var API = {
    "hasWorkers"              : hasWorkers ,
    "isMultiThread"           : isMultiThread ,
    "maxThreads"              : maxThreads ,
    "initCalc"                : initCalc ,
    "execCalc"                : execCalc ,
    "getThreadData"           : getThreadData
  } ;

  return API ;
} () ) ; // END ITER