h2non/thread.js

File thread.js has 876 lines of code (exceeds 250 allowed). Consider refactoring.

Open

/*! thread.js - v0.1.16 - MIT License - https://github.com/h2non/thread.js */
!function(e){if("object"==typeof exports&&"undefined"!=typeof module)module.exports=e();else if("function"==typeof define&&define.amd)define([],e);else{var f;"undefined"!=typeof window?f=window:"undefined"!=typeof global?f=global:"undefined"!=typeof self&&(f=self),f.thread=e()}}(function(){var define,module,exports;return (function e(t,n,r){function s(o,u){if(!n[o]){if(!t[o]){var a=typeof require=="function"&&require;if(!u&&a)return a(o,!0);if(i)return i(o,!0);var f=new Error("Cannot find module '"+o+"'");throw f.code="MODULE_NOT_FOUND",f}var l=n[o]={exports:{}};t[o][0].call(l.exports,function(e){var n=t[o][1][e];return s(n?n:e)},l,l.exports,e,t,n,r)}return n[o].exports}var i=typeof require=="function"&&require;for(var o=0;o<r.length;o++)s(r[o]);return s})({1:[function(require,module,exports){
var _ = require('./utils')
var workerSrc = require('./worker')

Function 8 has 245 lines of code (exceeds 25 allowed). Consider refactoring.

Open

},{}],8:[function(require,module,exports){
module.exports = worker

function worker() {
  var self = this

Function worker has 242 lines of code (exceeds 25 allowed). Consider refactoring.

Open

function worker() {
  var self = this

  function $$evalExpr(expr) {
    var fn = null

Function isolated has 233 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  (function isolated() {
    'use strict'

    var namespace = 'env'
    var isWorker = typeof document === 'undefined'

Function 6 has 174 lines of code (exceeds 25 allowed). Consider refactoring.

Open

},{"./utils":7}],6:[function(require,module,exports){
var _ = require('./utils')
var workerSrc = require('./worker')
var Task = require('./task')
var FakeWorker = require('./fake-worker')

Function 5 has 163 lines of code (exceeds 25 allowed). Consider refactoring.

Open

},{"./utils":7}],5:[function(require,module,exports){
var _ = require('./utils')

module.exports = Task

Function 1 has 89 lines of code (exceeds 25 allowed). Consider refactoring.

Open

!function(e){if("object"==typeof exports&&"undefined"!=typeof module)module.exports=e();else if("function"==typeof define&&define.amd)define([],e);else{var f;"undefined"!=typeof window?f=window:"undefined"!=typeof global?f=global:"undefined"!=typeof self&&(f=self),f.thread=e()}}(function(){var define,module,exports;return (function e(t,n,r){function s(o,u){if(!n[o]){if(!t[o]){var a=typeof require=="function"&&require;if(!u&&a)return a(o,!0);if(i)return i(o,!0);var f=new Error("Cannot find module '"+o+"'");throw f.code="MODULE_NOT_FOUND",f}var l=n[o]={exports:{}};t[o][0].call(l.exports,function(e){var n=t[o][1][e];return s(n?n:e)},l,l.exports,e,t,n,r)}return n[o].exports}var i=typeof require=="function"&&require;for(var o=0;o<r.length;o++)s(r[o]);return s})({1:[function(require,module,exports){
var _ = require('./utils')
var workerSrc = require('./worker')

var eventMethod = window.addEventListener ? 'addEventListener' : 'attachEvent'

Function 7 has 71 lines of code (exceeds 25 allowed). Consider refactoring.

Open

},{"./fake-worker":1,"./pool":3,"./store":4,"./task":5,"./utils":7,"./worker":8}],7:[function(require,module,exports){
var _ = exports
var toStr = Object.prototype.toString
var slice = Array.prototype.slice
var hasOwn = Object.prototype.hasOwnProperty

Function 3 has 63 lines of code (exceeds 25 allowed). Consider refactoring.

Open

},{"./store":4,"./thread":6}],3:[function(require,module,exports){
var _ = require('./utils')

module.exports = threadPool

Function 4 has 43 lines of code (exceeds 25 allowed). Consider refactoring.

Open

},{"./utils":7}],4:[function(require,module,exports){
var _ = require('./utils')

var buf = []
var store = module.exports = {}

Similar blocks of code found in 2 locations. Consider refactoring.

Open

function worker() {
  var self = this

  function $$evalExpr(expr) {
    var fn = null

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

Thread.prototype.require = Thread.prototype['import'] = function (name, fn) {
  if (_.isFn(name)) {
    fn = name
    name = _.fnName(fn)
    if (!name) throw new Error('function must be named')

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

Task.prototype.run = Task.prototype.exec = function (fn, env, args) {
  var thread = this.thread

  if (!thread || thread._terminated) {
    throw new Error('cannot execute the task. The thread was terminated')

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

function createThread(thread) {
  var src = _.getSource(workerSrc)
  if (hasWorkers && URL) {
    if (isIE) {
      thread.worker = new Worker(thread.options.evalPath)

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

function threadPool(poolSize, thread) {
  var threads = [ thread ]

  thread._run = thread.run
  thread._terminate = thread.terminate

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

Thread.prototype.run = Thread.prototype.exec = function (fn, env, args) {
  var task
  if (_.isArr(env)) {
    args = env
    env = arguments[2]

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

FakeWorker.prototype._subscribeListeners = function (type) {
  var listeners = this.listeners
  if (eventMethod === 'attachEvent') type = 'on' + type

  function eventHandler(e) {

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

exports.uuid = function () {
  var uuid = '', i, random
  for (i = 0; i < 32; i++) {
    random = Math.random() * 16 | 0;
    if (i === 8 || i === 12 || i === 16 || i === 20) uuid += '-'

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

function findBestAvailableThread(threads, offset) {
  var thread, pending
  for (var i = 0, l = threads.length; i < l; i += 1) {
    thread = threads[i]
    pending = thread.pending()

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

exports.each = function (obj, fn) {
  var i, l
  if (_.isArr(obj))
    for (i = 0, l = obj.length; i < l; i += 1) fn(obj[i], i)
  else if (_.isObj(obj))

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

function Task(thread, env) {
  this.id = _.uuid()
  this.thread = thread
  this.worker = thread.worker
  this.env = env || {}

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

FakeWorker.prototype.removeEventListener = function (type, fn) {
  var index, pool = this.listeners[type]
  if (pool) {
    if (_.isFn(fn)) {
      pool.splice(0, pool.length)

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

function selectThread(thread, threads, poolSize, args) {
  return function newRound(busyThreads) {
    var task, thread = findBestAvailableThread(threads, busyThreads)
    if (thread) {
      task = runTaskInThread(thread, threads, args)

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

FakeWorker.prototype._create = function () {
  var iframe = this.iframe = document.createElement('iframe')
  if (!iframe.style) iframe.style = {}
  iframe.style.display = 'none'
  iframe.id = 'thread-' + this.id

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

Thread.prototype.terminate = Thread.prototype.kill = function () {
  if (!this.terminated) {
    this.options = {}
    this.flushTasks().flush()
    this.terminated = true

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

FakeWorker.prototype._getWindow = function () {
  var win = null
  if (!this._terminated) {
    win = this.iframe.contentWindow
    var wEval = win.eval

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

exports.extend = function (target) {
  var args = _.toArr(arguments).slice(1)
  _.each(args, function (obj) {
    if (_.isObj(obj)) {
      _.each(obj, function (value, key) {

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

exports.serializeMap = function (obj) {
  if (_.isObj(obj)) {
    _.each(obj, function (fn, key) {
      if (_.isFn(fn)) {
        obj['$$fn$$' + key] = fn.toString()

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

function checkTaskDelay(time, maxDelay) {
  var error = null
  if ((_.now() - time) > maxDelay) {
    error = new Error('maximum task execution time exceeded')
    this.memoized = { type: 'run:error', error: error }

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

function onMessage(task) {
  return function handler(ev) {
    var data = ev.data
    if (data && data.id === task.id && isValidEvent(data.type)) {
      task.worker.removeEventListener('message', handler)

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

Task.prototype['finally'] = Task.prototype.finish = function (fn) {
  if (_.isFn(fn)) {
    if (this.memoized)
      fn.call(null, getValue(this.memoized))
    else

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

function createBlob(src) {
  var blob = null
  try {
    blob = new Blob([src], { type: 'text/javascript' })
  } catch (e) {

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

Thread.prototype.idle = Thread.prototype.sleep = function () {
  return !this.running() && !this.terminated
    && (this._latestTask === 0
    || (_.now() - this._latestTask) > this.idleTime)
}

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

function dispatcher(self, value) {
  return function recur(pool) {
    var fn = null
    if (_.isArr(pool)) {
      fn = pool.shift()

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

function checkInterval(task, maxDelay) {
  var now = _.now()
  task._timer = setInterval(function () {
    if (task.memoized) {
      clearTimer.call(task)

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

function Thread(options) {
  this.id = _.uuid()
  this.terminated = false
  this.options = {}
  this._tasks = []

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

function pushStateHandler(task, type, fn) {
  if (task.memoized) {
    if (task.memoized.type === ('run:' + type))
      fn.call(null, getValue(task.memoized))
  } else {

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

Task.prototype.then = Task.prototype.success = function (fn, errorFn) {
  if (_.isFn(fn)) pushStateHandler(this, 'success', fn)
  if (_.isFn(errorFn)) this['catch'](errorFn)
  return this
}

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

function cleanTask(thread, task) {
  return function () {
    var index = thread._tasks.indexOf(task)
    thread._latestTask = _.now()
    if (index >= 0) thread._tasks.splice(index, 1)

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

Thread.prototype.start = Thread.prototype.init = function (options) {
  if (this.terminated) {
    this._setOptions(options)
    this._create()
    this.terminated = false

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

function setOptions(thread, options) {
  thread.options.namespace = 'env'
  thread.options.require = []
  thread.options.env = {}
  _.extend(thread.options, thread.defaults, options)

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

FakeWorker.prototype.addEventListener = function (type, fn) {
  var pool = this.listeners[type] = this.listeners[type] || []
  if (_.isFn(fn)) pool.push(fn)
}

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

FakeWorker.prototype.postMessage = function (msg) {
  var win = this._getWindow()
  if (win) {
    msg.origin = _.getLocation()
    win.postMessage(msg, msg.origin)

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

Thread.prototype.off = Thread.prototype.removeEventListener = function (type, fn) {
  if (this.worker && _.isFn(fn)) {
    this.worker.removeEventListener(type, fn)
  }
  return this

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

function FakeWorker(id) {
  this.id = id
  this._terminated = false
  this.listeners = {}
  this._create()

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

FakeWorker.prototype.terminate = function () {
  this.listeners = {}
  this._terminated = true
  this._unsubscribeListeners()
  document.body.removeChild(this.iframe)

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

Thread.prototype.flushTasks = function () {
  _.each(this.tasks, function (task) {
    task.flush()
  })
  this._tasks.splice(0)

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

Task.prototype.flush = function () {
  this.memoized = this.thread = null
  this.worker = this.env = this.listeners = null
}

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

Thread.prototype.bind = Thread.prototype.set = function (env) {
  this.send({ type: 'env', data: _.serializeMap(env) })
  return this
}

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

exports.getLocation = function () {
  return location.origin
    || location.protocol + "//" + location.hostname + (location.port ? ':' + location.port : '')
}

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

function sendMessage(task, env, fn, args) {
  task.worker.postMessage({
    id: task.id,
    type: 'run',
    env: env,

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

FakeWorker.prototype._initialize = function (msg) {
  var win = this._getWindow()
  if (win) win.eval.call(win, _.getSource(workerSrc))
}

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

Thread.prototype.on = Thread.prototype.addEventListener = function (type, fn) {
  if (this.worker) this.worker.addEventListener(type, fn)
  return this
}

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

function getByStatus(type) {
  var typeBuf = []
  _.each(buf, function (thread) {
    if (thread[type]()) typeBuf.push(thread)
  })

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

store.killAll = function () {
  var arr = buf.slice()
  _.each(arr, function (thread) {
    thread.kill()
  })

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

function createError(data) {
  var err = new Error(data.error)
  err.name = data.errorName
  err.stack = data.errorStack
  return err

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

exports.fnName = function (fn) {
  return fn.name || (fn = /\W*function\s+([\w\$]+)\(/.exec(fn.toString()) ? fn[1] : '')
}

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

Task.prototype['catch'] = Task.prototype.error = function (fn) {
  if (_.isFn(fn)) pushStateHandler(this, 'error', fn)
  return this
}

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

function dispathEvent(task, value, type) {
  if (typeof task._timer === 'number') clearTimer.call(task)
  dispatcher(task, value)(task.listeners[type])
}

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

Thread.prototype.flush = function () {
  this.send({ type: 'flush' })
  this.options.env = {}
  return this
}

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

function triggerMessage(task, data) {
  var value = getValue(data)
  dispathEvent(task, value, data.type.split(':')[1])
  dispathEvent(task, value, 'end')
}

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

function createThread(threads) {
  var mainThread = threads[0]
  var thread = new mainThread.constructor(mainThread.options)
  threads.push(thread)
  return thread

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

store.remove = function (thread) {
  var index = buf.indexOf(thread)
  if (index >= 0) buf.splice(index, 1)
}

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

Task.prototype.bind = Task.prototype.set = function (env) {
  _.extend(this.env, env)
  return this
}

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

store.killIdle = function () {
  _.each(store.idle(), function (thread) {
    thread.kill()
  })
}

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

exports.isArr = function (o) {
  return o && (isArrayNative ? isArrayNative(o) : toStr.call(o) === '[object Array]') || false
}

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

function runTaskInThread(thread, threads, args) {
  var run = thread === threads[0] ? '_run' : 'run'
  return thread[run].apply(thread, args)
}

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

Thread.prototype.send = function (msg) {
  if (this.worker) {
    this.worker.postMessage(msg)
  }
}

• Read up
  Read up