update

Author: TLexYuW

05-restore-sequence/README.md renamed to 05-restore-sequence/_1/README.md

@@ -0,0 +1,53 @@
+Core :
+- 順序性: 步驟必須按順序執行
+- 可控制: 每個步驟都可以被控制和確認
+- 可恢復: 錯誤發生時可以從斷點恢復
+- 一致性: 確保數據和狀態的一致性
+
+Use Case :
+- 需要嚴格順序控制的流程
+- 長時間運行的任務
+- 需要支援斷點續做的操作
+- 對數據一致性要求高的場景
+
+
+```mermaid
+sequenceDiagram
+    participant M as Main
+    participant G as Generator
+    participant P as Processor
+    
+    M->>G: generateSequence()
+    activate G
+    
+    loop Each Step
+        G->>M: Send Step
+        activate M
+        
+        M->>P: processWithRetry(step, maxRetries)
+        activate P
+        
+        loop Retry Logic
+            P->>P: processStep()
+            alt Success
+                P-->>M: return true
+            else Error & Retries Left
+                Note over P: Wait and Retry
+                P->>P: retry++
+            else Error & No Retries
+                P-->>M: return false
+            end
+        end
+        deactivate P
+        
+        M->>G: step.waitFor <- success
+        Note over G: Wait for signal
+        G-->>M: Continue if received
+        deactivate M
+    end
+    
+    G-->>M: Close channels
+    deactivate G
+    
+    Note over M: Print Results
+```

05-restore-sequence/main.go renamed to 05-restore-sequence/_1/main.go

@@ -0,0 +1,138 @@
+package main
+
+import (
+	"fmt"
+	"math/rand"
+	"time"
+)
+
+type Step struct {
+	id      int
+	data    interface{}
+	waitFor chan bool
+}
+
+type StepProcessor struct {
+	lastSuccessful int
+	results        []string
+}
+
+func generateSequence() (<-chan Step, <-chan error) {
+	steps := make(chan Step)
+	errors := make(chan error, 1)
+
+	testData := []string{
+		"初始化系統",
+		"載入配置",
+		"連接數據庫",
+		"啟動服務",
+		"完成設定",
+	}
+
+	go func() {
+		defer close(steps)
+		defer close(errors)
+
+		for i, data := range testData {
+			// 為每個步驟創建等待channel
+			waitForIt := make(chan bool)
+
+			step := Step{
+				id:      i + 1,
+				data:    data,
+				waitFor: waitForIt,
+			}
+
+			steps <- step
+
+			// 等待步驟確認或超時
+			select {
+			case <-waitForIt:
+				fmt.Printf("步驟 %d 已確認完成\n", i+1)
+			case <-time.After(5 * time.Second):
+				errors <- fmt.Errorf("步驟 %d 等待超時", i+1)
+				return
+			}
+		}
+	}()
+
+	return steps, errors
+}
+
+func (sp *StepProcessor) processStep(step Step) error {
+	fmt.Printf("正在處理步驟 %d: %v\n", step.id, step.data)
+
+	time.Sleep(300 * time.Millisecond)
+
+	if rand.Float32() < 0.1 {
+		return fmt.Errorf("處理步驟 %d 時發生錯誤", step.id)
+	}
+
+	sp.lastSuccessful = step.id
+	sp.results = append(sp.results, fmt.Sprintf("步驟 %d (%v) 處理完成", step.id, step.data))
+
+	return nil
+}
+
+func (sp *StepProcessor) processWithRetry(step Step, maxRetries int) bool {
+	for retry := 0; retry <= maxRetries; retry++ {
+		if retry > 0 {
+			fmt.Printf("重試步驟 %d (第 %d 次)\n", step.id, retry)
+			time.Sleep(500 * time.Millisecond) // 重試前稍微等待
+		}
+
+		err := sp.processStep(step)
+		if err == nil {
+			return true // 處理成功
+		}
+
+		if retry < maxRetries {
+			fmt.Printf("錯誤: %v (已重試 %d/%d)\n", err, retry, maxRetries)
+		} else {
+			fmt.Printf("步驟 %d 重試次數超過上限，放棄處理\n", step.id)
+		}
+	}
+	return false // 所有重試都失敗
+}
+
+func NewStepProcessor() *StepProcessor {
+	return &StepProcessor{
+		lastSuccessful: 0,
+		results:        make([]string, 0),
+	}
+}
+
+func main() {
+	rand.Seed(time.Now().UnixNano())
+
+	processor := NewStepProcessor()
+	steps, errors := generateSequence()
+	maxRetries := 3
+
+	fmt.Println("開始處理序列...")
+	fmt.Println("====================")
+
+	for {
+		select {
+		case step, ok := <-steps:
+			if !ok {
+				fmt.Println("====================")
+				fmt.Println("序列處理完成！結果：")
+				for _, result := range processor.results {
+					fmt.Println(result)
+				}
+				return
+			}
+
+			// 使用重試機制處理步驟
+			success := processor.processWithRetry(step, maxRetries)
+
+			// 無論成功失敗，都要發送確認信號避免超時
+			step.waitFor <- success
+
+		case err := <-errors:
+			fmt.Printf("序列錯誤: %v\n", err)
+			return
+		}
+	}
+}