jjzjj

c# - 在我在同一进程中创建的所有其他线程死亡后停止线程

coder 2024-06-13 原文

我正在尝试编写一个任何进程都可以用于日志记录的库。我想在我的类中有一个专用的工作线程，它通过某种机制(管道、TCP 套接字等)将日志消息写入远程机器上的另一个进程，以便日志构造函数的代码看起来像这样(这样做的原因)这样一来，如果日志服务器在远程计算机上关闭，您就不会阻止正在日志记录的线程停止执行):

public LogWriter()
{
    queueWriter = new Thread(() =>
    {
        while (messageQueued.WaitOne())
        {
            Message message;
            while (messageQueue.TryDequeue(out message))
            {
                bool successful = false;
                while (!successful)
                {
                    try
                    {
                        _logger.PostMessage(message);
                        successful = true;
                    }
                    catch
                    {
                        try
                        {
                            _logger = new Logger();
                        }
                        catch { }
                    }
                }
            }
        }
    });
    queueWriter.Start();
}

所以如果你有一个应用程序，你可以像这样记录:

LogWriter logWriter = new LogWriter();
logWriter.Debug("This is an example of how you'd send a debug log to the writer. This message would get translated into a Message object, queued up, and the dedicated writer would be signaled to start writing queued messages.");

messageQueue是 ConcurrentQueue<Message> .我要queueWriter始终停止十秒在我在托管它的进程中明确创建的所有其他线程之后，除了它自己死掉，以便给它一些时间来完成它在其 messageQueue 中的日志的写入。 ，但不阻止进程关闭(所以十秒后，如果它还没有完成所有日志的写入，我们不再关心，只需停止线程)。

注意事项:

  • 制作queueWriter后台线程不够好。我不想杀queueWriter当父线程死亡时，因为它可能没有足够的时间来完成其待处理日志的写入。
  • 订阅Process.GetCurrentProcess().Exited也不够好。 queueWriter线程使进程保持运行。
  • 我希望它可以用作库，并且我不希望开发人员必须在应用程序或进程关闭 10 秒后手动向工作人员发出停止信号。我只是想能够跟踪到除了工作线程之外的所有线程都死了，等待十秒钟，然后关闭工作线程。
  • Process.GetCurrentProcess().Threads.Count 可能很方便，但是用它做一些测试，它会为您提供应用程序使用的所有线程(例如非托管线程、库线程，甚至是您未显式创建的线程)你自己，从某种意义上说，你还没有编写代码来显式启动该线程)。

那么如何做到这一点呢？有可能吗？

最佳答案

你不能用线程来做到这一点。不过，您可以使用单独的流程来完成。

您添加队列的原因可能是网络速度慢且不可靠。但是与同一台机器上的进程通信很快，快到足以同步通信。您可以监控进程，如果它死了就启动一个新进程。

关于c# - 在我在同一进程中创建的所有其他线程死亡后停止线程，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/24251153/

中创c#codesectionqueueWriter.netwindowsmultithreadingprocess

有关c# - 在我在同一进程中创建的所有其他线程死亡后停止线程的更多相关文章

  1. ruby - 其他文件中的 Rake 任务 - 2

    我试图在一个项目中使用rake，如果我把所有东西都放到Rakefile中，它会很大并且很难读取/找到东西，所以我试着将每个命名空间放在lib/rake中它自己的文件中，我添加了这个到我的rake文件的顶部:Dir['#{File.dirname(__FILE__)}/lib/rake/*.rake'].map{|f|requiref}它加载文件没问题，但没有任务。我现在只有一个.rake文件作为测试，名为“servers.rake”，它看起来像这样:namespace:serverdotask:testdoputs"test"endend所以当我运行rakeserver:testid时

  2. ruby - 如何将脚本文件的末尾读取为数据文件(Perl 或任何其他语言) - 2

    我正在寻找执行以下操作的正确语法(在Perl、Shell或Ruby中):#variabletoaccessthedatalinesappendedasafileEND_OF_SCRIPT_MARKERrawdatastartshereanditcontinues. 最佳答案 Perl用__DATA__做这个:#!/usr/bin/perlusestrict;usewarnings;while(){print;}__DATA__Texttoprintgoeshere 关于ruby-如何将脚

  3. ruby - 如何以所有可能的方式将字符串拆分为长度最多为 3 的连续子字符串？ - 2

    我试图获取一个长度在1到10之间的字符串，并输出将字符串分解为大小为1、2或3的连续子字符串的所有可能方式。例如:输入:123456将整数分割成单个字符，然后继续查找组合。该代码将返回以下所有数组。[1,2,3,4,5,6][12,3,4,5,6][1,23,4,5,6][1,2,34,5,6][1,2,3,45,6][1,2,3,4,56][12,34,5,6][12,3,45,6][12,3,4,56][1,23,45,6][1,2,34,56][1,23,4,56][12,34,56][123,4,5,6][1,234,5,6][1,2,345,6][1,2,3,456][123

  4. ruby - Highline 询问方法不会使用同一行 - 2

    设置:狂欢ruby1.9.2高线(1.6.13)描述:我已经相当习惯在其他一些项目中使用highline，但已经有几个月没有使用它了。现在，在Ruby1.9.2上全新安装时，它似乎不允许在同一行回答提示。所以以前我会看到类似的东西:require"highline/import"ask"Whatisyourfavoritecolor?"并得到:Whatisyourfavoritecolor?|现在我看到类似的东西:Whatisyourfavoritecolor?|竖线(|)符号是我的终端光标。知道为什么会发生这种变化吗？ 最佳答案

  5. ruby - 在 jRuby 中使用 'fork' 生成进程的替代方案？ - 2

    在MRIRuby中我可以这样做:deftransferinternal_server=self.init_serverpid=forkdointernal_server.runend#Maketheserverprocessrunindependently.Process.detach(pid)internal_client=self.init_client#Dootherstuffwithconnectingtointernal_server...internal_client.post('somedata')ensure#KillserverProcess.kill('KILL',

  6. ruby - 通过 ruby​​ 进程共享变量 - 2

    我正在编写一个gem，我必须在其中fork两个启动两个webrick服务器的进程。我想通过基类的类方法启动这个服务器，因为应该只有这两个服务器在运行，而不是多个。在运行时，我想调用这两个服务器上的一些方法来更改变量。我的问题是，我无法通过基类的类方法访问fork的实例变量。此外，我不能在我的基类中使用线程，因为在幕后我正在使用另一个不是线程安全的库。所以我必须将每个服务器派生到它自己的进程。我用类变量试过了，比如@@server。但是当我试图通过基类访问这个变量时，它是nil。我读到在Ruby中不可能在分支之间共享类变量，对吗？那么，还有其他解决办法吗？我考虑过使用单例，但我不确定这是

  7. ruby-on-rails - 跳过状态机方法的所有验证 - 2

    当我的预订模型通过rake任务在状态机上转换时，我试图找出如何跳过对ActiveRecord对象的特定实例的验证。我想在reservation.close时跳过所有验证!叫做。希望调用reservation.close!(:validate=>false)之类的东西。仅供引用，我们正在使用https://github.com/pluginaweek/state_machine用于状态机。这是我的预订模型的示例。classReservation["requested","negotiating","approved"])}state_machine:initial=>'requested

  8. ruby - RuntimeError(自动加载常量 Apps 多线程时检测到循环依赖 - 2

    我收到这个错误:RuntimeError(自动加载常量Apps时检测到循环依赖当我使用多线程时。下面是我的代码。为什么会这样？我尝试多线程的原因是因为我正在编写一个HTML抓取应用程序。对Nokogiri::HTML(open())的调用是一个同步阻塞调用，需要1秒才能返回，我有100,000多个页面要访问，所以我试图运行多个线程来解决这个问题。有更好的方法吗？classToolsController0)app.website=array.join(',')putsapp.websiteelseapp.website="NONE"endapp.saveapps=Apps.order("

  9. ruby - Nokogiri 剥离所有属性 - 2

    我有这个html标记:我想得到这个:我如何使用Nokogiri做到这一点？ 最佳答案 require'nokogiri'doc=Nokogiri::HTML('')您可以通过xpath删除所有属性:doc.xpath('//@*').remove或者，如果您需要做一些更复杂的事情，有时使用以下方法遍历所有元素会更容易:doc.traversedo|node|node.keys.eachdo|attribute|node.deleteattributeendend 关于ruby-Nokog

  10. ruby-on-rails - Rails - 从另一个模型中创建一个模型的实例 - 2

    我有一个正在构建的应用程序，我需要一个模型来创建另一个模型的实例。我希望每辆车都有4个轮胎。汽车模型classCar轮胎模型classTire但是，在make_tires内部有一个错误，如果我为Tire尝试它，则没有用于创建或新建的activerecord方法。当我检查轮胎时，它没有这些方法。我该如何补救？错误是这样的:未定义的方法'create'forActiveRecord::AttributeMethods::Serialization::Tire::Module我测试了两个环境:测试和开发，它们都因相同的错误而失败。 最佳答案

随机推荐