The processes from elixirscript

Can make a test code run

Dear maintainer of the this project, I'm trying to learn how to use this code by translate the following code into process.js

-module(counter_server).
-export([start/1, add/1, get/1]).


start(State) ->
    spawn(fun() -> loop(State) end).

add(Pid) ->
    cast(Pid, {add}).

get(Pid) ->
    call(Pid, {get}).

call(Pid, {Request}) ->
    Pid ! {Request, self()},
    receive
        Response -> Response
    end.

cast(Pid, {Request}) ->
    Pid ! {Request}.

loop(State) ->
    receive
        {add} ->
            loop(State + 1);
        {get, From} ->
            From ! State,
            loop(State)
    end.

the following is my attempt

const { ProcessSystem } = require("./process.js")

const system = new ProcessSystem()

main()

function main() {
    const p = start(10)
    console.log(get(p)) // undefined
}


function start(state) {
    return system.spawn(function*() {
        yield* loop(state)
    })
}

function add(pid) {
    cast(pid, ["add"])
}

function get(pid) {
    const G = ProcessSystem.run(call, [pid, ["get"]], this)
}

function* call(pid, [request]) {
    console.log("send") // never get called
    let response
    system.send([request, system.pid()])
    yield system.receive(response1 => response = response1)
    return response

}
function cast(pid, [request]) {
    system.send([request])
}

function* loop(state) {
    system.receive(([mesg, from]) => {
        console.log(mesg, from)
        if(mesg === "add" && !from)
            yield* loop(state + 1)
        else if(mesg === "get" && from) {
            console.log(from)
            system.send(from, state)
            yield* loop(state)
        }
    })
}

the first comment line log undefined, the second comment line never execute which I think where the problem is, Could you help a look where I did wrong

======= version 2

const { ProcessSystem } = require("./process.js")

const system = new ProcessSystem()

main()

function main() {
    const p = start(10)
    const g = get(p)
    const result = g.next()
    console.log(result)
}


function start(state) {
    return system.spawn(function*() {
        yield* loop(state)
    })
}

function add(pid) {
    cast(pid, ["add"])
}

function* get(pid) {
    yield* ProcessSystem.run(call, [pid, ["get"]], null)
}

function* call(pid, [request]) {
    let response
    system.send(pid, [request, system.pid()])
    console.log("mark1")
    yield system.receive(response1 => {
        response = response1
        console.log("mark2")
    })
    console.log("mark3")
    return response
}


function cast(pid, [request]) {
    system.send([request])
}
function* loop(state) {
    system.receive(([mesg, from]) => {
        console.log("mark4")
        if(mesg === "add" && !from)
            yield* loop(state + 1)
        else if(mesg === "get" && from) {
            console.log(from)
            system.send(from, state)
            yield* loop(state)
        }
    })
}

mark1
{ value: [ Symbol(receive), [Function], null, [Function: timeoutFn] ],
  done: false }

Fair TaskQueue

Right now the TaskQueue is FIFO. It would be better to implement a fair task queue implementation.

elixirscript / processes Goto Github PK

processes's People

Contributors

Stargazers

Watchers

Forkers

processes's Issues

Can make a test code run

Fair TaskQueue

Recommend Projects

React

Vue.js

Typescript

TensorFlow

Django

Laravel

D3

Recommend Topics

javascript

web

server

Machine learning

Visualization

Game

Recommend Org

Facebook

Microsoft

Google

Alibaba

D3

Tencent