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

engine/concurrentengine.go

@@ -6,21 +6,6 @@ import (
 	"log"
 )
 
-type Scheduler interface {
-	Submit(Request)
-
-	configureWorkChan(chan Request)
-}
-
-type ConcurrentEngine struct {
-	Scheduler Scheduler
-	Workcount int
-}
-
-type SimpleScheduler struct {
-	workerchan chan Request
-}
-
 func (s *SimpleScheduler) Submit(r Request) {
 
 	s.workerchan <- r

scheduler/quequescheduler.go

@@ -0,0 +1 @@
+package scheduler

scheduler/simpleScheduler.go

@@ -0,0 +1,18 @@
+package scheduler
+
+import "crawl/engine"
+
+type Scheduler interface {
+	Submit(engine.Request)
+
+	configureWorkChan(chan engine.Request)
+}
+
+type ConcurrentEngine struct {
+	Scheduler Scheduler
+	Workcount int
+}
+
+type SimpleScheduler struct {
+	workerchan chan engine.Request
+}