Pseudo Threads en Actionscript

Como mencione en un post anterior el Flash Player aunque internamente tiene un sistema de Threads o hilos que permite ejecutar multiples tareas al mismo tiempo, no provee a nosotros los desarrolladores la funcionalidad para utilizar threads nativamente. Esto hace por supuesto que aplicaciones nuestras donde se procesen muchos datos o con funciones o procesamiento muy pesado haga que nuestras aplicacion se congele o se pegue...
Como desarrolladores no tenemos otra forma de hacer que esto funcion sino es emulando la funcionalidad de los threads. Digo emulando porque no hay forma de hacerlo nativamente y se hace dividiendo el proceso pesado en multiples pedazos.
Acerca de esto se ha escrito en multiples lugares con contenido muy completo y excelentes soluciones a distintos niveles de complejidad.
Las librerias anteriores y muchas otras lo que hacen es partir el proceso grande en multiples pedazos que seran ejecutados en momentos distintos. Esto disminuye la carga de trabajo y hace que el proceso no se ejecute de un solo sin permitir al FP refrescarse y por lo tanto pegarse.
Sin embargo de las librerias anteriores, mi favorita es la de Grant Skinner, se llama "Chunker" pues parte los procesos en pedazos. Sin embargo basado en esa clase, decidi hacer unas modificaciones que aqui presento:

package com.grayscale.util.threads
{
import flash.display.Shape;
import flash.events.Event;
import flash.events.EventDispatcher;
import flash.utils.getTimer;

/** 
 * Evento despachado cuando se concluye el proceso.
 */
[Event (type="flash.events.Event", name="complete")]

/**
 * Esta clase es una implementacion simple de un pseudo thread en AS3. 
 * 
Esta basada en la clase de Grant Skinner aunque con algunas modificaciones.
 *  http://www.gskinner.com/libraries/Chunker.zip
 */
public class SimpleThread extends EventDispatcher
{
 //Nos permite tener acceso al evento ENTER_FRAME que sera el que lleve el  
 //paso de cada cuando se ejecutaran nuestros procesos.
 private var shape:Shape = new Shape();
 //Estado del hilo
 private var _paused:Boolean = false;
 //Cada cuanto se ejecutara
 private var _execTime:uint;
 //Funcion a ejecutar
 private var _func:Function;
 //Argumentos a nuestra funcion. Es un array de elementos que pasariamos a nuestra funcion
 private var _args:Array;
 
 /**
  * Constructor.
  * 
  * @param execTime Cada cuanto se ejecutara nuestra funcion
  * @param func funcion a ejecutar
  * @param args parametro opcional con los valores a pasarse en la funcion
  */
 public function SimpleThread(execTime:int, func:Function, args:Array=null)
 {
  _execTime = execTime;
  _func = func;
  _args = args;
  
  pause = false;   
 }
 
 /**
  * Para el thread o lo arranca
  */
 public function set pause(value:Boolean):void
 {
  _paused = value;
  if(_paused) shape.removeEventListener(Event.ENTER_FRAME, run);
  else shape.addEventListener(Event.ENTER_FRAME, run);
 }
 
 
 /**
  * Metodo que ejecuta nuestra funcion
  */
 private function run(event:Event):void
 {
  var initialTime:int = getTimer();//registra el tiempo donde  inicia este iteracion
  while(!_paused && (getTimer() < _execTime+initialTime ))//revisa si no hemos excedido la cantidad de tiempo del inicio
  {
   //llama nuestra funcion y esta tiene que regresar un valor booleano. Si este es falso detiene el thread sino continua.    
   var res:Boolean = _func.apply(this, _args) as Boolean 
   if(!res)//ya se termina de ejecutar nuestra funcion, pausamos el thread y despachamos evento avisando que se concluyo
   {
    dispatchEvent(new Event(Event.COMPLETE));
    pause = true;
   }
  }
 }
}
}

El unico requisito para esta clase, es que la funcion que queremos partir debe devolver un valor booleano: true si todavia hay data que procesar, false si ya termino de procesar la informacion.
A continuacion presento dos ejemplos, ambos cargan el mismo archivo(analytics de este blog); uno lo hace sin los pseudo-threads y otro con el pseudo-thread. Podran ver la diferencia como uno se pega y el otro no. Es un archivo grande (4mb) asi que tengan paciencia. Apenas se carga se activa el boton de "Start"
Notas: 1. Debe aparecer un spinner cuando se aprieta el boton de "start". 2. los controles de la pantalla deben ser accesbles mientras se procesan los datos.

Sin Thread.




Con Thread.



Al partir nuestra funcionalidad en multiples ejecuciones y no solo en una, ocupamos una forma de llegar a saber donde terminamos de procesar y desde donde debemos empezar. Para esto puedo sugerir el uso del patron Iterator. Este patron permite a una coleccion encapsular la manera en que se recorre la coleccion y guardar dentro de si misma cual fue el ultimo elemento procesado, sin tener que tener mantener un indice de la coleccion por fuera. El iterador se encarga de todo. Esto es bueno ya que al partir nuestro proceso ocupamos mantener una referencia al dato que estamos procesando sin tener que crear otras variables.
Aqui presento las siguientes clases para tener nuestro iterator.

Interfaz Base:

package com.grayscale.util.iterator
{
/**
 * Esta interfaz define los metodos basicos que debera contener un iterador en nuestra coleccion
 * @author Ivan Ramirez - ivan.ramirez@gmail.com
 */
public interface IIterator
{
 /**
  * Devuelve "true" si tenemos mas valores que recorrer dentro de nuestra coleccion
  */
 function hasNext():Boolean;
 /**
  * Devuelve el proximo valor en nuestro iterador
  * @returns el siguiente objeto en la coleccion.
  */
 function next():*;
 /**
  * Nos permite reiniciar el recorrido de nuestra coleccion
  */
 function reset():void;  
}
}

Implementacion basica:

package com.grayscale.util.iterator
{
/**
 * Implementacion basica de nuestro iterator para el manejo de arrays. Podemos implementar esta interfaz
 * en otras clases para hacer iteradores con Strings o de XML, etc.
 * @author Ivan Ramirez - ivan.ramirez@gmail.com
 */
public class ArrayIterator implements IIterator
{
 //Coleccion base
 private var collection:Array = new Array();
 private var index:int; 
 
 public function ArrayIterator(values:Array)
 {
  collection = values
 }

 public function hasNext():Boolean
 {
  return index < collection.length;
 }
 
 public function next():*
 {
  return collection[index++];
 }
 
 public function reset():void
 {
  index = 0;
 }
 
}
}

La ventaja de tener una interfaz definiendo el iterador, es que podemos crear nuestras propias implementaciones del iterador de acuerdo a nuestras necesidades.
Ya con nuestro iterador cargado con la coleccion de datos que tenemos que procesar, procedemos a utilizar nuestro thread.

El codigo de las aplicaciones de este ejemplo esta aqui.