Merge pull request #27 from antlabs/dev

更新

Author: guonaihong

task/stream2/stream2_executor.go

@@ -58,6 +58,7 @@ func (s *stream2Executor) run(mu *sync.Mutex) bool {
 	var f func() bool
 	for i := 0; ; i++ {
 		if mu != nil {
+			// 加锁
 			mu.Lock()
 		}
 
@@ -76,6 +77,14 @@ func (s *stream2Executor) run(mu *sync.Mutex) bool {
 			return false
 		}
 
+		if i >= len(s.list) {
+			s.list = s.list[0:0]
+			if mu != nil {
+				mu.Unlock()
+			}
+			return false
+		}
+
 		f = s.list[i]
 		s.list[i] = nil
 		if mu != nil {