同步线程 - 无 UI

Question

我正在尝试编写多线程代码并面临一些同步问题。我知道这里有很多帖子，但我找不到合适的内容。

我有一个 System.Timers.Timer，每 30 秒就会进入数据库并检查是否有任何新作业。如果他找到一个，他就会在当前线程上执行该作业（计时器在每次过去后打开新线程）。当作业运行时，我需要通知主线程（计时器所在的位置）有关进度。

注意：

1. 我没有 UI，所以我无法像通常在 winforms 中那样执行 beginInvoke （或使用后台线程）。
2. 我想在我的主类上实现 ISynchronizeInvoke ，但这看起来有点矫枉过正（也许我错了）。
3. 我的作业类中有一个事件，主类向它注册，并且我在需要时调用该事件，但我担心它可能会导致阻塞。
4. 每个作业最多可能需要 20 分钟。
5. 我最多可以同时运行 20 个作业。

我的问题是：

通知我的主线程有关工作线程中的任何进度的正确方法是什么？

感谢您的任何帮助。

Answer 1

您还可以使用 lock 实现线程安全的 JobManager 类，用于跟踪不同工作线程的进度。在此示例中，我仅维护活动工作线程计数，但这可以扩展到您的进度报告需求。

class JobManager
{
    private object synchObject = new object();

    private int _ActiveJobCount;

    public int ActiveJobsCount
    {
        get { lock (this.synchObject) { return _ActiveJobCount; } }
        set { lock (this.synchObject) { _ActiveJobCount = value; } }
    }

    public void Start(Action job)
    {
        var timer = new System.Timers.Timer(1000);

        timer.Elapsed += (sender, e) =>
        {
            this.ActiveJobsCount++;
            job();
            this.ActiveJobsCount--;
        };

        timer.Start();
    }
}

例子：

class Program
{
    public static void Main(string[] args)
    {
        var manager = new JobManager();

        manager.Start(() => Thread.Sleep(3500));

        while (true)
        {
            Console.WriteLine(manager.ActiveJobsCount);

            Thread.Sleep(250);
        }
    }
}

Answer 2

您可以通过回调方法通知主线程进度。也就是说：

// in the main thread
public void ProgressCallback(int jobNumber, int status)
{
    // handle notification
}

当您调用它时（即作为委托），您可以将该回调方法传递给工作线程，或者工作线程的代码可以隐式“知道”它。无论哪种方式都有效。

jobNumber 和 status 参数只是示例。您可能希望使用其他方式来标识正在运行的作业，并且可能希望使用枚举类型来表示状态。无论您如何执行，请注意 ProgressCallback 将由多个线程同时调用，因此如果您要更新任何共享数据结构或写入日志记录信息，则必须使用锁或其他同步技术来保护这些资源。

您也可以使用事件来实现此目的，但保持主线程的事件订阅最新可能是一个潜在的问题。如果您忘记取消主线程对特定工作线程事件的订阅，也可能会出现内存泄漏。尽管事件肯定会起作用，但我建议此应用程序使用回调。

Answer 3

使用事件。例如，BackgroundWorker 类是专门为您的想法而设计的。

http://msdn.microsoft.com/en-us/ library/system.componentmodel.backgroundworker.aspx

ReportProgress 函数以及 ProgressChanged 事件是您用于进度更新的函数。

pullJobTimer.Elapsed += (sender,e) =>
{
    BackgroundWorker worker = new BackgroundWorker();
    worker.WorkerReportsProgress = true;
    worker.DoWork += (s,e) =>
    {
        // Whatever tasks you want to do
        // worker.ReportProgress(percentComplete);
    };
    worker.ProgressChanged += mainThread.ProgressChangedEventHandler;
    worker.RunWorkerAsync();
};

Answer 4

如果您不介意依赖.NET 3.0，您可以使用 调度程序来编组线程之间的请求。它的行为方式与 Windows 窗体中的 Control.Invoke() 类似，但不具有窗体依赖性。不过，您需要添加对 WindowsBase 程序集的引用（.NET 3.0 和更新版本的一部分，是 WPF 的基础）

如果您不能依赖 .NET 3.0 那么我会说您我们从一开始就采取了正确的解决方案：实施 ISynchronizeInvoke 主类中的接口并将其传递给 计时器的 SynchronizingObject 属性。然后，您的计时器回调将在主线程上调用，然后可以生成 BackgroundWorkers 检查数据库并运行任何排队的作业。这些作业将通过 ProgressChanged 报告进度事件将自动封送对主线程的调用。

通过 Google 快速搜索，发现了此示例，了解如何实际实现 ISynchronizeInvoke 接口。