Skip to content
This repository was archived by the owner on May 1, 2024. It is now read-only.
This repository was archived by the owner on May 1, 2024. It is now read-only.

Channels and gorountines in js #6

@vladimir-vg

Description

@vladimir-vg

I also thought about go to js translator, pretty awesome idea.

What about this kind of channels/gorountines implementation:

var Go = (function () {
  var result = {package: {}};

    /* chan */

    var chan = function () {
        this.getCallbackStack = [];
        this.putCallbackStack = [];
    };

    chan.prototype.put = function (value, callback) {
        if (this.getCallbackStack.length == 0) {
            this.putCallbackStack.push({value: value, callback: callback});
        } else {
            var getCallback = this.getCallbackStack.pop().callback;
            if (getCallback) {
                getCallback(value);
            }
            if (callback) {
                callback();
            }
        }
    };

    chan.prototype.get = function (callback) {
        if (this.putCallbackStack.length == 0) {
            this.getCallbackStack.push({callback: callback});
        } else {
            var elt = this.putCallbackStack.pop();
            var putCallback = elt.callback, value = elt.value;
            if (callback) {
                callback(value);
            }
            if (putCallback) {
                putCallback();
            }
        }
    };

    result.chan = chan;

    /* goroutine */

    result.go = function (callback, arguments) {
        arguments = arguments || [];
        setTimeout(function () {
            callback.apply(null, arguments);
        }, 0);
    };

    result.println = function (value) {
        console.log(value);
    };

    return result;
})();

Go.package["time"] = {

    Second: 1000,

    Sleep: function (duration, callback) {
        setTimeout(callback, duration)
    }
};

And example of use:

// package main
//
// import "time"
//
// func main() {
//   ch := make(chan bool)
//  go func() {
//      println("Locked")
//      <-ch
//      println("Unlocked")
//      ch <- true
//  }()
//  time.Sleep(time.Second*2)
//  ch <- true
//  <- ch
// }

(function () {
    var time = Go.package["time"];
    var ch = new Go.chan();
    Go.go(function () {
        Go.println("Locked");
        ch.get(function (value) {
            Go.println("Unlocked");
            ch.put(true);
        });
    });
    time.Sleep(time.Second*2, function () {
        ch.put(true, function () {
            ch.get();
        });
    });
})();

This in this code channels have capacity equal to 1, but can be easily tuned to support buffered channels.

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions