-
-
Notifications
You must be signed in to change notification settings - Fork 2.6k
/
mergesort.go
94 lines (73 loc) · 1.56 KB
/
mergesort.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
// mergesort.go
// description: Implementation of merge sort algorithm
// worst-case time complexity: O(n log n)
// average-case time complexity: O(n log n)
// space complexity: O(n)
package sort
import (
"github.com/TheAlgorithms/Go/constraints"
"github.com/TheAlgorithms/Go/math/min"
"sync"
)
func merge[T constraints.Ordered](a []T, b []T) []T {
var r = make([]T, len(a)+len(b))
var i = 0
var j = 0
for i < len(a) && j < len(b) {
if a[i] <= b[j] {
r[i+j] = a[i]
i++
} else {
r[i+j] = b[j]
j++
}
}
for i < len(a) {
r[i+j] = a[i]
i++
}
for j < len(b) {
r[i+j] = b[j]
j++
}
return r
}
// Merge Perform merge sort on a slice
func Merge[T constraints.Ordered](items []T) []T {
if len(items) < 2 {
return items
}
var middle = len(items) / 2
var a = Merge(items[:middle])
var b = Merge(items[middle:])
return merge(a, b)
}
func MergeIter[T constraints.Ordered](items []T) []T {
for step := 1; step < len(items); step += step {
for i := 0; i+step < len(items); i += 2 * step {
tmp := merge(items[i:i+step], items[i+step:min.Int(i+2*step, len(items))])
copy(items[i:], tmp)
}
}
return items
}
// ParallelMerge Perform merge sort on a slice using goroutines
func ParallelMerge[T constraints.Ordered](items []T) []T {
if len(items) < 2 {
return items
}
if len(items) < 2048 {
return Merge(items)
}
var wg sync.WaitGroup
wg.Add(1)
var middle = len(items) / 2
var a []T
go func() {
defer wg.Done()
a = ParallelMerge(items[:middle])
}()
var b = ParallelMerge(items[middle:])
wg.Wait()
return merge(a, b)
}