How to use Go language for code parallelization practice
In modern software development, performance is a very important consideration. In order to improve code execution efficiency, we can use parallel programming technology. As a concurrent programming language, Go language has a wealth of parallelization tools and features that can help us achieve good parallelization of code.
This article will introduce how to use Go language for code parallelization practice, starting from basic concurrency processing to complex parallel algorithm optimization.
Goroutine is a lightweight thread in the Go language. It is managed by the runtime system of the Go language. To start a goroutine, just use the keyword "go". We can use goroutines to perform multiple tasks at the same time.
The sample code is as follows:
package main import ( "fmt" ) func hello(name string) { fmt.Println("Hello,", name) } func main() { names := []string{"Alice", "Bob", "Charlie"} for _, name := range names { go hello(name) } }
In the above code, we execute the hello function at the same time by starting three goroutines, and each goroutine will output a greeting. Note that since goroutines are executed concurrently, the order of output may be different.
The sample code is as follows:
package main import ( "fmt" "runtime" "sync" ) func calculate(start, end int, wg *sync.WaitGroup) { defer wg.Done() sum := 0 for i := start; i <= end; i++ { sum += i } fmt.Println("Result:", sum) } func main() { runtime.GOMAXPROCS(runtime.NumCPU()) var wg sync.WaitGroup wg.Add(4) go calculate(1, 1000, &wg) go calculate(1001, 2000, &wg) go calculate(2001, 3000, &wg) go calculate(3001, 4000, &wg) wg.Wait() }
In the above code, we define a calculate function to calculate the sum of integers within a certain range. Wait for the completion of the calculation task by using sync.WaitGroup. Use the runtime.NumCPU() function to obtain the number of CPU cores of the current system, and set the maximum parallel number of goroutines to the number of CPU cores through the runtime.GOMAXPROCS() function.
We start four goroutines to simultaneously perform different ranges of calculation tasks. Each goroutine will calculate a part of the integer sum. Finally, we use sync.WaitGroup to wait for all calculation tasks to complete.
The sample code is as follows:
package main import ( "fmt" "sort" "sync" ) func parallelSort(data []int, wg *sync.WaitGroup) { sort.Ints(data) wg.Done() } func main() { data := []int{9, 7, 5, 3, 1, 8, 6, 4, 2, 0} fmt.Println("Before sort:", data) var wg sync.WaitGroup wg.Add(1) go parallelSort(data, &wg) wg.Wait() fmt.Println("After sort:", data) }
In the above code, we define a parallelSort function to sort integer slices in parallel. Sort the slices by using the sort.Ints function, and then wait for the completion of the sorting task through sync.WaitGroup.
We execute the parallel sorting algorithm by starting a goroutine and wait for the completion of the sorting task. Finally, we output the sorted results.
Summary:
Go language provides powerful parallelization tools and features, which can easily achieve parallelization of code. By using goroutines and channels to implement basic concurrency processing, by using parallel computing to accelerate code execution, and by using parallel algorithms to further optimize code performance, we can give full play to the concurrency advantages of the Go language and improve code execution efficiency.
The above is the detailed content of How to use Go language for code parallelization practice. For more information, please follow other related articles on the PHP Chinese website!