Multi-thread Share

index.js

let cluster     = require( 'cluster' ),
    gid         = 0,
    callbackMap = new Map

if ( cluster.isMaster ) {
    const cache = new Map

    cluster.on( 'message', ( worker, message ) => {
        let value

        if ( message.type === 'get' ) {
            value = {
                id   : message.id,
                ok   : true,
                value: cache.get( message.key )
            }
        } else {
            cache.set( message.key, message.value )
            value = {
                id: message.id,
                ok: true
            }
        }
        worker.send( value )
    } )
} else {
    process.on( 'message', ( msg ) => {
        let callback = callbackMap.get( msg.id )

        if ( callback ) {
            callback( !msg.ok, msg )
        }
    } )
}

module.exports = {
    set( key, value, callback ) {
        let id = gid++
        callback && callbackMap.set( id, callback )

        process.send( {
            id,
            type: 'set',
            key, value
        } )
    },

    get( key, callback ) {
        let id = gid++
        callback && callbackMap.set( id, callback )

        process.send( {
            id,
            type: 'get',
            key
        } )
    }
}

test.js

let cluster = require( 'cluster' ),
    tool    = require( './index' ),
    cpuNum  = require( 'os' ).cpus().length

let obj = {
        name: 123
    },
    key = 'a'

if ( cluster.isMaster ) {
    while ( cpuNum-- ) {
        cluster.fork()
    }
} else {
    if ( cluster.worker.id === 1 ) {
        tool.set( key, obj )

        setTimeout( () => {
            tool.get( key, ( err, data ) => {
                console.log( 'result is ', data.value )
            } )
        }, 1000 )
    }

    if ( cluster.worker.id === 2 ) {
        setTimeout( () => {
            tool.get( key, ( err, data ) => {
                console.log( '2 === ', data )
            } )
        }, 3000 )
    }
}