adiciona diretório de concurrency

Author: davidnuneslima

concurrency/channels.go

@@ -0,0 +1,17 @@
+package main
+
+import "fmt"
+
+func producer(ch chan string) {
+	ch <- "Message from Producer"
+	close(ch)
+}
+
+func main() {
+	ch := make(chan string)
+	go producer(ch)
+
+	for msg := range ch {
+		fmt.Println(msg)
+	}
+}

concurrency/goroutines.go

@@ -0,0 +1,20 @@
+// Praticando o paralelismo com go.
+
+package main
+
+import (
+	"fmt"
+	"time"
+)
+
+func printMessage(msg string) {
+	for i := 0; i < 5; i++ {
+		fmt.Println(msg)
+		time.Sleep(500 * time.Millisecond)
+	}
+}
+
+func main() {
+	go printMessage("Hello from Goroutine!")
+	printMessage("Hello from Main!")
+}

concurrency/select.go

@@ -0,0 +1,30 @@
+package main
+
+import (
+	"fmt"
+	"time"
+)
+
+func main() {
+	ch1 := make(chan string)
+	ch2 := make(chan string)
+
+	go func() {
+		time.Sleep(1 * time.Second)
+		ch1 <- "Message from Channel 1"
+	}()
+
+	go func() {
+		time.Sleep(2 * time.Second)
+		ch2 <- "Message from Channel 2"
+	}()
+
+	for i := 0; i < 2; i++ {
+		select {
+		case msg1 := <-ch1:
+			fmt.Println(msg1)
+		case msg2 := <-ch2:
+			fmt.Println(msg2)
+		}
+	}
+}