js/productor_consumidor.js
// numero de mensajes que soporta el buffer
numero de mensajes que soporta el buffer
numero de mensajes que soporta el buffer
function AppViewModel() {
    self = this;
    let bufferMensajes = new SharedArrayBuffer(N);
    let mensajes = new Int32Array(bufferMensajes);
    this.init = function () {
        const productor = new Worker('js/productor.js');
        const consumidor = new Worker('js/consumidor.js');
        productor.onmessage = function (e) {
            consumidor.postMessage(e.data);
        };
        consumidor.onmessage = function (e) {
            productor.postMessage(e.data);
        };
        consumidor.postMessage(null);
    };
    this.init();
    return this;
}
function AppViewModel ( ) { self = this ; let bufferMensajes = new SharedArrayBuffer ( N ) ; let mensajes = new Int32Array ( bufferMensajes ) ; this . init = function ( ) { const productor = new Worker ( 'js/productor.js' ) ; const consumidor = new Worker ( 'js/consumidor.js' ) ; productor . onmessage = function ( e ) { consumidor . postMessage ( e . data ) ; } ; consumidor . onmessage = function ( e ) { productor . postMessage ( e . data ) ; } ; consumidor . postMessage ( null ) ; } ; this . init ( ) ; return this ; }
numero de mensajes que soporta el buffer
numero de mensajes que soporta el buffer
// Crea un area compartida en la memoria, tamaño N // Mensaje recibido de productor, devolver a consumidor // Mensaje recibido de consumidor, devolver a productor