五一快乐，隔离一时爽，一直隔离一直爽

scheduler/quequescheduler.go

@@ -1 +1,55 @@
 package scheduler
+
+import (
+	"crawl/engine"
+)
+
+type QueueScheluder struct {
+	requestChan chan engine.Request
+	workerChan  chan chan engine.Request //二维通道
+
+}
+
+func (s QueueScheluder) Submit(r engine.Request) {
+	s.requestChan <- r
+}
+
+func (s QueueScheluder) configureWorkChan(chan engine.Request) {
+	panic("implement me")
+}
+
+func (s *QueueScheluder) workReady(w chan engine.Request) {
+
+	s.workerChan <- w
+}
+
+func (s *QueueScheluder) Run() {
+
+	var requestQ []engine.Request
+	var workQ []chan engine.Request
+	go func() {
+		for {
+			var activeRequest engine.Request
+			var activeWork engine.Request
+
+			if len(requestQ) > 0 && len(workQ) > 0 {
+				activeRequest = requestQ[0]
+				activeWork = workQ[0]
+
+			}
+
+			select {
+
+			case r := <-s.requestChan:
+				requestQ = append(requestQ, r)
+			case w := <-s.workerChan:
+				workQ = append(workQ, w)
+			case activeWork <- activeRequest:
+				workQ = workQ[1:]
+				requestQ = requestQ[1:]
+
+			}
+
+		}
+	}()
+}