Skip to content

Commit a67e311

Browse files
yogesh-jsyogesh-js
authored
Add files via upload
1 parent b7534b3 commit a67e311

File tree

45 files changed

+3512
-0
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

45 files changed

+3512
-0
lines changed

‎22Maths/go.mod‎

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,3 @@
1+
module github.com/Aniket762/namaste-go/maths
2+
3+
go 1.17

‎22Maths/main‎

1.97 MB
Binary file not shown.

‎22Maths/main.go‎

Lines changed: 29 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,29 @@
1+
package main
2+
3+
import (
4+
"fmt"
5+
"math/big"
6+
7+
// "math/rand"
8+
"crypto/rand"
9+
)
10+
11+
func main() {
12+
fmt.Println("Getting into Maths functions and variables 🙏")
13+
/*
14+
var One int =3
15+
var Two float64 =5.3
16+
17+
fmt.Println(One + int(Two)) // loosing precision over here!
18+
*/
19+
20+
// random number math/rand
21+
// driven by seed so changing the value of seed
22+
// rand.Seed(time.Now().UnixNano())
23+
// fmt.Println(rand.Intn(100))
24+
25+
// random numbers from cryptp/rand
26+
// doesn't depend on seed
27+
RandomNum , _ := rand.Int(rand.Reader, big.NewInt(100))
28+
fmt.Println(RandomNum)
29+
}

‎23goroutines/go.mod‎

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,3 @@
1+
module github.com/Aniket762/namaste-go/goroutines
2+
3+
go 1.17

‎23goroutines/main.go‎

Lines changed: 111 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,111 @@
1+
package main
2+
3+
import (
4+
"fmt"
5+
"net/http"
6+
"sync"
7+
"time"
8+
)
9+
10+
// for multi threading we need wait groups
11+
var wg sync.WaitGroup // pointer
12+
13+
14+
// understanding mutex
15+
var mut sync.Mutex
16+
var signals = []string{}
17+
18+
func main() {
19+
// its concurrently works
20+
go greeter("Getting into")
21+
greeter("Go routines 🙏")
22+
23+
waitlist := []string{
24+
"https://google.com",
25+
"https://aniketpal.vercel.app",
26+
"https://github.com",
27+
}
28+
29+
// single thread operation
30+
for _, website := range waitlist{
31+
GetStatusCode(website)
32+
}
33+
34+
// multi thread operation - go routines
35+
// using waitgroups for time sync
36+
for _, website := range waitlist{
37+
go GetStatusCodeWait(website)
38+
wg.Add(1)
39+
}
40+
wg.Wait()
41+
}
42+
43+
func greeter(s string) {
44+
for i :=0; i<3;i++{
45+
/*
46+
using sleep so that concurrency breaks
47+
and func start to execute the statement again
48+
else the function which goes works on thread
49+
never gets excecuted as we are not providing a restart sort of thing for the server.
50+
*/
51+
time.Sleep(2 * time.Millisecond)
52+
fmt.Println(s)
53+
}
54+
}
55+
56+
// single thread
57+
func GetStatusCode(endpoint string) {
58+
res , err := http.Get(endpoint)
59+
60+
if err!= nil{
61+
fmt.Println("Endpoint not reachable")
62+
}else{
63+
fmt.Printf("%d status code for %s\n",res.StatusCode,endpoint)
64+
}
65+
}
66+
67+
// multi thread
68+
func GetStatusCodeWait(endpoint string) {
69+
defer wg.Done()
70+
res , err := http.Get(endpoint)
71+
72+
if err!= nil{
73+
fmt.Println("Endpoint not reachable")
74+
}else{
75+
// until one thread is executed it will not do anything more
76+
mut.Lock()
77+
signals = append(signals, endpoint)
78+
mut.Unlock()
79+
fmt.Printf("%d status code for %s\n",res.StatusCode,endpoint)
80+
}
81+
}
82+
83+
/*
84+
In cloud there is no shortage of threads
85+
and go routines are not absolutely dependent on OS
86+
to generate a thread to excecute. So it becomes efficient to
87+
use Go in cloud native architecture.
88+
89+
90+
---
91+
92+
Thread:
93+
- Managed by OS
94+
- Fixed Stack 1MB
95+
96+
Go Routines
97+
- Managed by Go Runtime
98+
- Flexible length 2KB
99+
*/
100+
101+
102+
/*
103+
Mutex is a mutual exclusion lock. The zero
104+
value fo Mutex is an unlocked mutex.
105+
106+
It looks the memory , so when one goroutine is writing
107+
something in the memory it will not allow anything else to write on it
108+
109+
Similarly for RWMutex
110+
While one operation is being running it will run until interrupted
111+
*/

‎24racecondition/go.mod‎

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,3 @@
1+
module github.com/Aniket762/namaste-go/racecondition
2+
3+
go 1.17

‎24racecondition/main.go‎

Lines changed: 49 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,49 @@
1+
package main
2+
3+
import (
4+
"fmt"
5+
"sync"
6+
)
7+
8+
func main() {
9+
fmt.Println("Getting into Race condition 🙏")
10+
11+
wg := &sync.WaitGroup{}
12+
mut := &sync.RWMutex{}
13+
14+
var score = []int{0}
15+
16+
wg.Add(3)
17+
go func(wg *sync.WaitGroup, m *sync.RWMutex) {
18+
fmt.Println("One R")
19+
mut.Lock()
20+
score = append(score, 1)
21+
mut.Unlock()
22+
wg.Done()
23+
}(wg, mut)
24+
//wg.Add(1)
25+
go func(wg *sync.WaitGroup, m *sync.RWMutex) {
26+
fmt.Println("Two R")
27+
mut.Lock()
28+
score = append(score, 2)
29+
mut.Unlock()
30+
wg.Done()
31+
}(wg, mut)
32+
go func(wg *sync.WaitGroup, m *sync.RWMutex) {
33+
fmt.Println("Three R")
34+
mut.Lock()
35+
score = append(score, 3)
36+
mut.Unlock()
37+
wg.Done()
38+
}(wg, mut)
39+
go func(wg *sync.WaitGroup, m *sync.RWMutex) {
40+
fmt.Println("Three R")
41+
mut.RLock()
42+
fmt.Println(score)
43+
mut.RUnlock()
44+
wg.Done()
45+
}(wg, mut)
46+
47+
wg.Wait()
48+
fmt.Println(score)
49+
}

‎25channels/go.mod‎

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,3 @@
1+
module github.com/Aniket762/namaste-go/channels
2+
3+
go 1.17

‎25channels/main.go‎

Lines changed: 38 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,38 @@
1+
package main
2+
3+
import (
4+
"fmt"
5+
"sync"
6+
)
7+
8+
func main() {
9+
fmt.Println("Getting into channels 🙏 ")
10+
11+
myCh := make(chan int, 2)
12+
wg := &sync.WaitGroup{}
13+
14+
// fmt.Println(<-myCh)
15+
// myCh <- 5
16+
wg.Add(2)
17+
// R ONLY
18+
go func(ch <-chan int, wg *sync.WaitGroup) {
19+
20+
val, isChanelOpen := <-myCh
21+
22+
fmt.Println(isChanelOpen)
23+
fmt.Println(val)
24+
25+
//fmt.Println(<-myCh)
26+
27+
wg.Done()
28+
}(myCh, wg)
29+
// send ONLY
30+
go func(ch chan<- int, wg *sync.WaitGroup) {
31+
myCh <- 0
32+
close(myCh)
33+
// myCh <- 6
34+
wg.Done()
35+
}(myCh, wg)
36+
37+
wg.Wait()
38+
}

0 commit comments

Comments
 (0)