สวัสดีครับ ในบทความนี้ก็เป็น EP.5 แล้วนะครับ โดยเนื้อหาจะเป็นเรื่องเกี่ยวกับ Go Routine ซึ่งเป็นเรื่องสําคัญมากในการพัฒนาโปรแกรมด้วยภาษา Go เพราะจะช่วยให้เราสามารถพัฒนาโปรแกรมที่มี Performance ที่ดีครับ

สําหรับท่านใดที่ยังไม่ได้อ่าน EP.4 ท่านสามารถกลับไปอ่านก่อนได้นะครับที่นี่ Go EP.4 Syntax ของภาษา Go

มาเริ่มเรียนรู้ไปด้วยกันตามหัวข้อด้านล่างเลยครับ

Go Routine คืออะไร

โดยปกติเมื่อเราเขียนโปรแกรมภาษา Go ตัวโปรแกรมจะ Run Code ไปทีละบรรทัดจากบนลงล่าง ซึ่งจะใช้ CPU เพียง 1 Core เท่านั้น ตามตัวอย่างนี้ครับ

package main

import (
	"fmt"
	"time"
)

func main() {
	start := time.Now()

	task1()
	task2()
	task3()

	fmt.Println("ใช้เวลาในการ Run ทั้งสิ้น : ", time.Since(start))
}

func task1(){
	time.Sleep(3 * time.Second)
	fmt.Println("Task1 success")
}

func task2(){
	time.Sleep(5 * time.Second)
	fmt.Println("Task2 success")
}

func task3(){
	time.Sleep(3 * time.Second)
	fmt.Println("Task3 success")
}

// ผลลัพธ์จากการ Run

// Task1 success
// Task2 success
// Task3 success
// ใช้เวลาในการ Run ทั้งสิ้น :  11s

จะเห็นว่าในแต่ละ Task จะทํางานไปตามลําดับ ทําให้เวลารวมของการทํางานในโปรแกรมนี้คือ 9 วินาที

แต่การใช้ Go Routine คือการเขียน Code ให้สามารถทํางานหลายๆอย่างในเวลาเดียวกัน หรือสามารถ Run งานด้วย CPU 2 Core นั่นเอง หมายความว่าโปรแกรมที่เราเขียนจะมีประสิทธิภาพมากขึ้น

มาดูวิธีการใช้งานตามหัวข้อถัดไปได้เลยครับ

Go Routine ใช้งานยังไร

การใช้งาน Go Routine คือเราสามารถใส่ keyword “go” ไว้หน้า Function ที่เราต้องการจะให้แยก Thread ออกไปทํางาน function นั้นจะแยก Thread ออกไปทํางานทันที ลองดูตามตัวอย่างนี้ครับ

package main

import (
	"fmt"
	"time"
)

func main() {
	start := time.Now()

	task1()
	go task2()
	task3()

	fmt.Println("ใช้เวลาในการ Run ทั้งสิ้น : ", time.Since(start))
}

func task1(){
	time.Sleep(3 * time.Second)
	fmt.Println("Task1 success")
}

func task2(){
	time.Sleep(5 * time.Second)
	fmt.Println("Task2 success")
}

func task3(){
	time.Sleep(3 * time.Second)
	fmt.Println("Task3 success")
}

// ผลลัพธ์จากการ Run

// Task1 success
// Task3 success
// ใช้เวลาในการ Run ทั้งสิ้น :  6s

จากตัวอย่างด้านบนจะเห็นว่า Task2 หายไป เนื่องจาก Task2 แยก Thread ออกไปทํางานแต่ยังทํางานไม่เสร็จ แต่ Main thread ทํางานจบก่อนทําให้โปรแกรมจบการทํางาน Task2 จึงไม่ถูกทํางานต่อจนจบ

เรามาลองเปลี่ยนใหม่โดยเพิ่ม Sleep ก่อนที่จะจบโปรแกรมเพื่อรอให้ Task2 ทํางานเสร็จก่อน ตามนี้ครับ

package main

import (
	"fmt"
	"time"
)

func main() {
	start := time.Now()

	task1()
	go task2()
	task3()

	allTime := time.Since(start) // วัดเวลาการทํางานเฉพาะ Task1, Task2, Task3 เท่านั้น

	time.Sleep(5 * time.Second)

	fmt.Println("ใช้เวลาในการ Run ทั้งสิ้น : ", allTime)
}

func task1(){
	time.Sleep(3 * time.Second)
	fmt.Println("Task1 success")
}

func task2(){
	time.Sleep(5 * time.Second)
	fmt.Println("Task2 success")
}

func task3(){
	time.Sleep(3 * time.Second)
	fmt.Println("Task3 success")
}

// Task1 success
// Task3 success
// Task2 success
// ใช้เวลาในการ Run ทั้งสิ้น :  6s

จะเห็นว่าเราได้เพิ่ม “time.Sleep(5 * time.Second)” เพื่อรอ 5 วินาที ทําให้ Task2 สามารถทํางานได้จนเสร็จ และที่สําคัญ เวลาในการทํางานของ Task1, Task2, Task3 รวมกันลดลงจาก 11s เหลือ 6s

สําหรับในการใช้งานจริงเราจะไม่ใช้ Sleep เพื่อรอแบบนี้นะครับ เราจะใช้สิ่งที่เรียกว่า Channel ซึ่งเป็นเรื่องสําคัญในการใช้งานร่วมกับ Go Routine

ขอให้สนุกกับการเขียน Code นะครับ ขอบคุณครับ

สําหรับ EP. ต่อไปจะเป็นเรื่อง Go EP.6 Go Channel เข้าไปอ่านต่อได้เลยครับ