WP7 - 在应用程序停用或关闭时无法正常退出 bg 线程

Question

我的数据密集型 wp7 应用程序保存数据如下：我维护一个反映所有用户活动的更改日志，每隔几秒，线程计时器就会启动一个线程池线程，将更改日志刷新到事务内的数据库。它看起来像这样：

当用户退出时，我停止计时器，刷新 UI 线程上的日志（不超过一两秒），然后卸载数据库。

但是，如果用户退出时工作线程处于活动状态，我无法弄清楚如何优雅地做出反应。系统似乎杀死了工作线程，因此它永远不会完成其工作，也永远不会放弃其对数据库连接的锁，然后ui线程尝试获取锁，并立即被系统杀死。我尝试在 UI 线程上设置一个标志，请求工作线程中止，但我认为工作线程在读取该标志之前就被中断了。一切工作正常，除了百分之一的情况，其中一些用户更改最终没有保存到数据库，我似乎无法解决这个问题。

下面非常简化的代码：

private Timer _SweepTimer = new Timer(SweepCallback, null, 5000, 5000);

private volatile bool _BailOut = false;
private void SweepCallback(object state) {
    lock (db) { 
        db.startTransaction();

        foreach(var entry in changeJournal){
            //CRUD entry as appropriate
            if(_BailOut){
                db.rollbackTransaction();
                return;
            }
        }

        db.endTransaction();
        changeJournal.Clear();
    }
}

private void RespondToSystemExit(){
    _BailOut = true; //Set flag for worker to exit

    lock(db){ //In theory, should acquire the lock after the bg thread bails out
        SweepCallback(null);//Flush to db on the UI thread
        db.dismount();//App is now ready to close
    }
}

Answer 1

好吧，为了结束这个问题，我最终使用了手动重置事件而不是锁定，据我所知，这是对手动重置事件的误用，有风险和黑客行为，但总比没有好。

我仍然不知道为什么我的原始代码不起作用。

编辑：为了后代，我重新发布代码以从 MS 论坛重现此内容：

//This is a functioning console app showing the code working as it should. Press "w" and then "i" to start and then interrupt the worker
using System;
using System.Threading;

namespace deadlocktest {
    class Program {
        static void Main(string[] args) {
            var tester = new ThreadTest();
            string input = "";
            while (!input.Equals("x")) {
                input = Console.ReadLine();

                switch (input) {
                    case "w":
                        tester.StartWorker();
                        break;
                    case "i":
                        tester.Interrupt();
                        break;
                    default:
                        return;
                }
            }
        }
    }

    class ThreadTest{
        private Object lockObj = new Object();
        private volatile bool WorkerCancel = false;

        public void StartWorker(){
            ThreadPool.QueueUserWorkItem((obj) => {
                if (Monitor.TryEnter(lockObj)) {
                    try {
                        Log("Worker acquired the lock");
                        for (int x = 0; x < 10; x++) {
                            Thread.Sleep(1200);
                            Log("Worker: tick" + x.ToString());
                            if (WorkerCancel) {
                                Log("Worker received exit signal, exiting");
                                WorkerCancel = false;
                                break;
                            }
                        }
                    } finally {
                        Monitor.Exit(lockObj);
                        Log("Worker released the lock");
                    }
                } else {
                    Log("Worker failed to acquire lock");
                }
            });
        }

        public void Interrupt() {
            Log("UI thread - Setting interrupt flag");
            WorkerCancel = true;

            if (Monitor.TryEnter(lockObj, 5000)) {
                try {
                    Log("UI thread - successfully acquired lock from worker");
                } finally {
                    Monitor.Exit(lockObj);
                    Log("UI thread - Released the lock");
                }
            } else {
                Log("UI thread - failed to acquire the lock from the worker");
            }
        }

        private void Log(string Data) {
            Console.WriteLine(string.Format("{0} - {1}", DateTime.Now.ToString("mm:ss:ffff"), Data));
        }
    }
}

这里是几乎相同的代码，但在 WP7 上失败，只需制作一个带有两个按钮的页面并挂钩它们

using System;
using System.Diagnostics;
using System.Threading;
using System.Windows;
using Microsoft.Phone.Controls;

namespace WorkerThreadDemo {
    public partial class MainPage : PhoneApplicationPage {
        public MainPage() {
            InitializeComponent();
        }

        private Object lockObj = new Object();
        private volatile bool WorkerCancel = false;
        private void buttonStartWorker_Click(object sender, RoutedEventArgs e) {
            ThreadPool.QueueUserWorkItem((obj) => {
                if (Monitor.TryEnter(lockObj)) {
                    try {
                        Log("Worker acquired the lock");
                        for (int x = 0; x < 10; x++) {
                            Thread.Sleep(1200);
                            Log("Worker: tick" + x.ToString());
                            if (WorkerCancel) {
                                Log("Worker received exit signal, exiting");
                                WorkerCancel = false;
                                break;
                            }
                        }
                    } finally {
                        Monitor.Exit(lockObj);
                        Log("Worker released the lock");
                    }
                } else {
                    Log("Worker failed to acquire lock");
                }
            });
        }

        private void Log(string Data) {
            Debug.WriteLine(string.Format("{0} - {1}", DateTime.Now.ToString("mm:ss:ffff"), Data));
        }

        private void buttonInterrupt_Click(object sender, RoutedEventArgs e) {
            Log("UI thread - Setting interrupt flag");
            WorkerCancel = true;

            //Thread.Sleep(3000); UNCOMMENT ME AND THIS WILL START TO WORK! 
            if (Monitor.TryEnter(lockObj, 5000)) {
                try {
                    Log("UI thread - successfully acquired lock from worker");
                } finally {
                    Monitor.Exit(lockObj);
                    Log("UI thread - Released the lock");
                }
            } else {
                Log("UI thread - failed to acquire the lock from the worker");
            }
        }
    }
}

Answer 2

当您通过 Application_Deactivated 或 Application_Closing 事件进行操作时，您的方法应该有效。 MSDN 说：

停用事件的完成有时间限制。这
如果应用程序花费的时间超过 10，设备可能会终止该应用程序
保存瞬态状态的秒数。

因此，如果您说只需要几秒钟，那应该没问题。除非文档没有讲述整个故事。或者你的工作线程退出所需的时间比你想象的要长。

Answer 3

正如 Heinrich Ulbricht 已经说过的，你有 <=10 秒的时间来完成你的东西，但是你应该阻止 MainThread 来获取它们。

这意味着即使您的 BG 线程有很多工作要做，但您的 UI 线程在 OnClosingEvent/OnDeactivatingEvent 中什么也不做 - 您将不会获得 10 秒的时间。

我们的应用程序实际上在关闭事件中对 UI 线程进行永久等待，以允许 BG 线程通过套接字发送一些数据。