postMessage from worker: many small msgs or single large (v2)

Revision 2 of this benchmark created by Andrew Petersen on October 21, 2013

Description

Preparation HTML

<script type="text/javascript">
function forTheWorker() {

  var id = 0;
  var mode = '';

  onmessage = function(ev) {
    if (ev.data.mode) mode = ev.data.mode;
    postUpdates();
  }

  function makeUpdate() {
    var msg = {
      type: 'boid update',
      id: ++id,
      x: Math.random(),
      y: Math.random(),
      radius: 8
    };
    return msg;
  }

  function makeStringUpdate() {
    var msg = 'type:boid update'
      + ',id:' + (++id)
      + ',x:' + Math.random()
      + ',y:' + Math.random()
      + ',radius:' + 8;
    return msg;
  }

  function postUpdates() {
    var i, max = 400, msgs;
    if (mode === 'batched') {
      msgs = [];
      for(i = 0; i < max; i++) {
        msgs.push(makeUpdate());
      }
      postMessage({ type: 'boid updates', updates: msgs });
    }

    if (mode === 'batched string') {
      msgs = [];
      for(i = 0; i < max; i++) {
        msgs.push(makeStringUpdate());
      }
      postMessage({ type: 'boid updates', updates: msgs });
    }

    if (mode === 'batched string no structure') {
      msgs = []
      for(i = 0; i < max; i++) {
        msgs.push(makeStringUpdate());
      }
      postMessage(msgs.join('+'));
    }

    if (mode === 'singles') {
      for(i = 0; i < max; i++) {
        postMessage(makeUpdate());
      }
    }

    if (mode === 'singles string') {
      for(i = 0; i < max; i++) {
        postMessage(makeStringUpdate());
      }
    }

    postMessage('updateend');
  }
}

var jssrc = '(' + forTheWorker.toString() + '())';
var jsblob = new Blob([jssrc], { type: 'text/javascript' });
var jsURL = window.URL.createObjectURL(jsblob);

var w = new Worker(jsURL);

function tick(mode) {
  w.postMessage({ mode: mode });
}

var currentDeferred = null;
function useDeferred(deferred) {
  currentDeferred = deferred;
}

w.onmessage = function(ev) {
  if (currentDeferred && ev.data === 'updateend') {
    currentDeferred.resolve(ev.data);
    return;
  }

  // For local testing when currentDeferred is not defined
  if (ev.data === 'updateend') return;

  var parsed;

  // Single string encoded
  //if (typeof ev.data === 'string') {
  //  parsed = parseString(ev.data);
  //  //console.log('parsed', parsed);
  //  return;
  //}

  // Multiple encoded strings
  if (ev.data.updates && typeof ev.data.updates[0] === 'string') {
    for (var i = 0; i < ev.data.updates.length; i++) {
      parsed = parseString(ev.data.updates[i]);
      //console.log('parsed', parsed);
    }
    return;
  }

  // Single string with multiple encoded updates
  if (typeof ev.data === 'string') {
    parsed = parseMultipleString(ev.data);
    //console.log('parsed', parsed);
    return;
  }
}

function parseString(str) {
  var parts = str.split(',');
  var obj = {};
  var part;
  for(var i = 0; i < parts.length; i++) {
    part = parts[i].split(':');
    obj[part[0]] = part[1];
  }
  return obj;
}

function parseMultipleString(str) {
  var parts = str.split('+');
  var i = 0, all = [];
  while(i < parts.length) {
    all.push(parseString(parts[i]));
    i++;
  }
  return all;
}

</script>

Test runner

// async test
useDeferred(deferred);
tick('batched');
 

// async test
useDeferred(deferred);
tick('batched string');

// async test
useDeferred(deferred);
tick('batched string no structure');
 

Revisions

You can edit these tests or add more tests to this page by appending /edit to the URL.

• Revision 1: published by Andrew Petersen on October 17, 2013
• Revision 2: published by Andrew Petersen on October 21, 2013
• Revision 3: published by Andrew Petersen on December 30, 2013
• Revision 4: published on March 20, 2014
• Revision 5: published by Alexander on March 20, 2014