diff --git a/frameworks/native/backup_kit_inner/src/b_session_restore_async.cpp b/frameworks/native/backup_kit_inner/src/b_session_restore_async.cpp
index dc43c86d5eaeea73b936ee4d47172684fb275b68..c25212f5d2189f34823469e5804f00e1bcdd77c9 100644
--- a/frameworks/native/backup_kit_inner/src/b_session_restore_async.cpp
+++ b/frameworks/native/backup_kit_inner/src/b_session_restore_async.cpp
@@ -43,41 +43,6 @@ BSessionRestoreAsync::~BSessionRestoreAsync()
     deathRecipient_ = nullptr;
 }
 
-void BSessionRestoreAsync::InitSession(std::vector<BundleName> bundlesToRestore)
-{
-    std::unique_lock<std::mutex> lock(mutex_);
-    if (isAlive_.load() == true) {
-        return;
-    }
-    ServiceProxy::InvaildInstance();
-    auto proxy = ServiceProxy::GetInstance();
-    if (proxy == nullptr) {
-        return OnBundleStarted(BError(BError::Codes::SDK_BROKEN_IPC, "Failed to get backup service").GetCode(),
-                               bundlesToRestore);
-    }
-    std::function<void()> onBackupServiceDied;
-    try {
-        onBackupServiceDied = bind(&BSessionRestoreAsync::OnBackupServiceDied, shared_from_this());
-    } catch(const std::bad_function_call &err) {
-        HILOGE("Failed to Init Restore because of %{public}s", err.what());
-        return OnBundleStarted(BError(BError::Codes::SDK_BROKEN_IPC, "Failed to get backup service").GetCode(),
-                               bundlesToRestore);
-    }
-    RegisterBackupServiceDied(onBackupServiceDied);
-
-    BSessionRestore::Callbacks callbacksTmp {.onFileReady = callbacks_.onFileReady,
-                                             .onBundleStarted = callbacks_.onBundleStarted,
-                                             .onBundleFinished = callbacks_.onBundleFinished,
-                                             .onAllBundlesFinished = callbacks_.onAllBundlesFinished,
-                                             .onBackupServiceDied = onBackupServiceDied};
-    int32_t res = proxy->InitRestoreSession(new ServiceReverse(callbacksTmp));
-    if (res != 0) {
-        HILOGE("Failed to Init Restore because of %{public}d", res);
-        return OnBundleStarted(res, bundlesToRestore);
-    }
-    isAlive_.store(true);
-}
-
 shared_ptr<BSessionRestoreAsync> BSessionRestoreAsync::Init(Callbacks callbacks)
 {
     try {
@@ -113,12 +78,17 @@ ErrCode BSessionRestoreAsync::AppendBundles(UniqueFd remoteCap,
                                             RestoreTypeEnum restoreType,
                                             int32_t userId)
 {
-    InitSession(bundlesToRestore);
-    if (isAlive_.load() == true) {
-        AppendBundlesImpl({move(remoteCap), move(bundlesToRestore), restoreType, userId});
+    {
+        std::unique_lock<std::mutex> lock(mutex_);
+        workList_.push({move(remoteCap), move(bundlesToRestore), restoreType, userId});
+    }
+
+    if (isAppend_.exchange(true)) {
+        return ERR_OK;
     } else {
-        return BError(BError::Codes::SDK_BROKEN_IPC, "Failed to int restore session").GetCode();
+        PopBundleInfo();
     }
+
     return ERR_OK;
 }
 
@@ -145,18 +115,54 @@ void BSessionRestoreAsync::OnBackupServiceDied()
         callbacks_.onBackupServiceDied();
     }
     deathRecipient_ = nullptr;
-    isAlive_.store(false);
+    ServiceProxy::InvaildInstance();
+    PopBundleInfo();
+}
+
+void BSessionRestoreAsync::PopBundleInfo()
+{
+    HILOGE("Start");
+    AppendBundleInfo info;
+    isAppend_.store(true);
+    {
+        std::unique_lock<std::mutex> lock(mutex_);
+        if (workList_.empty()) {
+            isAppend_.store(false);
+            return;
+        }
+        info = move(workList_.front());
+        workList_.pop();
+    }
+    AppendBundlesImpl(move(info));
 }
 
 void BSessionRestoreAsync::AppendBundlesImpl(AppendBundleInfo info)
 {
     HILOGD("Start");
+    ServiceProxy::InvaildInstance();
     auto proxy = ServiceProxy::GetInstance();
     if (proxy == nullptr) {
         return OnBundleStarted(BError(BError::Codes::SDK_BROKEN_IPC, "Failed to get backup service").GetCode(),
                                info.bundlesToRestore);
     }
-    int32_t res =
+    auto onBackupServiceDied = bind(&BSessionRestoreAsync::OnBackupServiceDied, shared_from_this());
+    RegisterBackupServiceDied(onBackupServiceDied);
+
+    BSessionRestore::Callbacks callbacksTmp {.onFileReady = callbacks_.onFileReady,
+                                             .onBundleStarted = callbacks_.onBundleStarted,
+                                             .onBundleFinished = callbacks_.onBundleFinished,
+                                             .onAllBundlesFinished = callbacks_.onAllBundlesFinished,
+                                             .onBackupServiceDied = onBackupServiceDied};
+    int32_t res = proxy->InitRestoreSession(new ServiceReverse(callbacksTmp));
+    if (res != 0) {
+        HILOGE("Failed to Init Restore because of %{public}d", res);
+        BError(BError::Codes::SDK_BROKEN_IPC, "Failed to int restore session").GetCode();
+        return OnBundleStarted(res, info.bundlesToRestore);
+    }
+    for (auto &bundleName : info.bundlesToRestore) {
+        HILOGD("Append bundleName: %{public}s", bundleName.c_str());
+    }
+    res =
         proxy->AppendBundlesRestoreSession(move(info.remoteCap), info.bundlesToRestore, info.restoreType, info.userId);
     if (res != 0) {
         HILOGE("Failed to Restore because of %{public}d", res);
diff --git a/interfaces/inner_api/native/backup_kit_inner/impl/b_session_restore_async.h b/interfaces/inner_api/native/backup_kit_inner/impl/b_session_restore_async.h
index fdbc46bad73c35cfa3a3035c1b9af6ef41fd101c..0d547909e6a2a709015cb4e3ec560a2527ddc4be 100644
--- a/interfaces/inner_api/native/backup_kit_inner/impl/b_session_restore_async.h
+++ b/interfaces/inner_api/native/backup_kit_inner/impl/b_session_restore_async.h
@@ -119,18 +119,12 @@ private:
      */
     void RegisterBackupServiceDied(std::function<void()> functor);
 
-    /**
-     * @brief Backup Session init
-     *
-     * @param bundlesToRestore
-     */
-    void InitSession(const std::vector<BundleName> bundlesToRestore);
-
 private:
     sptr<SvcDeathRecipient> deathRecipient_;
     Callbacks callbacks_;
-    std::atomic<bool> isAlive_ {false};
+    std::atomic<bool> isAppend_ {false};
     std::mutex mutex_;
+    std::queue<AppendBundleInfo> workList_;
 };
 } // namespace OHOS::FileManagement::Backup