add linear go to skeleton

littleGauze · May 28, 2015 · 69d6435 · 69d6435
1 parent 12185a6
commit 69d6435
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 3 deletions.
diff --git a/go/go.go b/go/go.go
@@ -71,10 +71,10 @@ func (c *LinearContext) Go(f func(), cb func()) {
 		defer c.mutexExecution.Unlock()
 
 		c.mutexLinearGo.Lock()
-		lg := c.linearGo.Remove(c.linearGo.Front()).(*LinearGo)
+		e := c.linearGo.Remove(c.linearGo.Front()).(*LinearGo)
 		c.mutexLinearGo.Unlock()
 
-		lg.f()
-		c.g.ChanCb <- lg.cb
+		e.f()
+		c.g.ChanCb <- e.cb
 	}()
 }
diff --git a/module/skeleton.go b/module/skeleton.go
@@ -78,6 +78,14 @@ func (s *Skeleton) Go(f func(), cb func()) {
 	s.g.Go(f, cb)
 }
 
+func (s *Skeleton) NewLinearContext() *g.LinearContext {
+	if s.GoLen == 0 {
+		panic("invalid GoLen")
+	}
+
+	return s.g.NewLinearContext()
+}
+
 func (s *Skeleton) RegisterChanRPC(id interface{}, f interface{}) {
 	if s.ChanRPCServer == nil {
 		panic("invalid ChanRPCServer")