Initial commit

Author: roshangade

.gitignore

@@ -10,3 +10,8 @@
 
 # Output of the go coverage tool, specifically when used with LiteIDE
 *.out
+
+# editors
+.idea
+.DS_Store
+.vscode

LICENSE

@@ -1,6 +1,6 @@
 MIT License
 
-Copyright (c) 2019 Go Lang | REST Services
+Copyright (c) 2019 Roshan Gade
 
 Permission is hereby granted, free of charge, to any person obtaining a copy
 of this software and associated documentation files (the "Software"), to deal

README.md

@@ -1,2 +1,6 @@
 # async
 Perform multiple asynchronous tasks concurrently.
+
+
+# INCOMPLETE
+Working on it

async.go

@@ -0,0 +1,36 @@
+/*!
+ * go-rs/async
+ * Copyright(c) 2019 Roshan Gade
+ * MIT Licensed
+ */
+package async
+
+type Task func() interface{}
+type Result chan interface{}
+
+type Promise struct {
+	//TODO:
+	//Context - Cancel, Timeout
+	//Concurrency vs Parallelism
+	//What to do on error? Is it best way to abort all operation?
+}
+
+func (p *Promise) All(tasks []Task) []Result {
+	workers := make([]Result, 0, len(tasks))
+	for _, task := range tasks {
+		result := execute(task)
+		workers = append(workers, result)
+	}
+	return workers
+}
+
+func execute(task Task) Result {
+	out := make(Result)
+	{
+		go func() {
+			defer close(out)
+			out <- task()
+		}()
+	}
+	return out
+}

examples/main.go

@@ -0,0 +1,31 @@
+package main
+
+import (
+	"fmt"
+	"time"
+
+	"github.com/go-rs/async"
+)
+
+func main() {
+	fmt.Println("start")
+	var promise async.Promise
+
+	tasks := []async.Task{
+		func() interface{} {
+			time.Sleep(1000 * time.Microsecond)
+			return "Hello"
+		},
+		func() interface{} {
+			time.Sleep(100 * time.Microsecond)
+			return "World"
+		},
+	}
+
+	for _, a := range promise.All(tasks) {
+		// switch statement for results
+		fmt.Println(<-a)
+	}
+
+	fmt.Println("exit")
+}