diff --git a/sync_engine.go b/sync_engine.go
index 1de86609f1fd26394ee7f2a50b1e89baf00dbb0b..f2fcc14c9a75209fee6deae685af2a1bd06d7741 100644
--- a/sync_engine.go
+++ b/sync_engine.go
@@ -24,6 +24,11 @@ func NewEngine(ctx context.Context) Engine {
 }
 
 func NewEngineWithOption(ctx context.Context, options ...EngineOption) Engine {
+	p, err := NewPool(100)
+	if err != nil {
+		panic(err)
+	}
+	
 	eng := &syncEngine{
 		lock:            sync.Mutex{},
 		queue:           make(chan CommandTask, 10),
@@ -31,9 +36,10 @@ func NewEngineWithOption(ctx context.Context, options ...EngineOption) Engine {
 		commandHandlers: make(map[string]Command, 0),
 		taskNum:         0,
 		transfer:        NewDefaultTransfer(),
+		pool:            p,
 	}
 	
-	err := eng.WithEngineOptions(options...)
+	err = eng.WithEngineOptions(options...)
 	if err != nil {
 		eng.SetErr(err)
 	}