Round Robin

---

Định nghĩa

Thuật toán Round Robin phân phối yêu cầu theo vòng tuần tự:

index = (index + 1) % N

Trong đó:

• N là số server (hoặc worker/task consumer)

• index là chỉ số server hiện tại

---

Pseudo Code chuẩn

servers = [S1, S2, S3, S4]
current = 0

function getServer():
    server = servers[current]
    current = (current + 1) mod length(servers)
    return server

---

Golang Implementation

package main

import (
	"fmt"
	"sync"
)

type RoundRobin struct {
	servers []string
	index   int
	mu      sync.Mutex
}

func NewRoundRobin(servers []string) *RoundRobin {
	return &RoundRobin{servers: servers, index: 0}
}

func (rr *RoundRobin) Next() string {
	rr.mu.Lock()
	defer rr.mu.Unlock()

	server := rr.servers[rr.index]
	rr.index = (rr.index + 1) % len(rr.servers)
	return server
}

func main() {
	rr := NewRoundRobin([]string{"S1", "S2", "S3"})

	for i := 0; i < 10; i++ {
		fmt.Println(rr.Next())
	}
}

Điểm quan trọng:

• Dùng sync.Mutex để tránh race condition khi chạy multi-goroutine.

---

Java Implementation

import java.util.List;
import java.util.concurrent.atomic.AtomicInteger;

public class RoundRobin {
    private final List<String> servers;
    private final AtomicInteger index = new AtomicInteger(0);

    public RoundRobin(List<String> servers) {
        this.servers = servers;
    }

    public String next() {
        int i = index.getAndIncrement();
        return servers.get(i % servers.size());
    }

    public static void main(String[] args) {
        RoundRobin rr = new RoundRobin(List.of("S1", "S2", "S3"));
        for (int i = 0; i < 10; i++) {
            System.out.println(rr.next());
        }
    }
}

Điểm hay:

• Dùng AtomicInteger → thread-safe → tránh synchronization nặng.

---

Biến thể: Weighted Round Robin

Cho phép máy mạnh nhận nhiều request hơn.

Server	Weight
S1	5
S2	1

Cách expand list đơn giản:

expanded = [S1, S1, S1, S1, S1, S2]
→ chạy Round Robin như bình thường

Hoặc dùng thuật toán Smooth Weighted Round Robin (ngon hơn, Kubernetes/Envoy/nginx đều dùng).

---

TL;DR (gist)

• Round Robin quay vòng: index = (index + 1) % N

• Thread-safe Golang dùng sync.Mutex

• Thread-safe Java dùng AtomicInteger

• Thích hợp stateless service; không phù hợp long-lived connections.

• Weighted Round Robin = phân tải theo trọng số.