当前位置: 首页 > 面试题库 >

我该如何分批处理流程?

居晗日
2023-03-14
问题内容

我想派生一个go进程并获取新进程的ID,但是我在execos库中看到的只是启动一个新进程。


问题答案:

您应该syscall.ForkExec()syscall包装中获取。

请注意,这fork()是在根本不使用任何线程的情况下发明的,并且一个进程中始终只有一个执行线程,因此分叉是安全的。使用Go,情况完全不同,因为它大量使用OS级线程来为其goroutine调度提供动力。

现在,fork(2)在Linux上未经修饰的子进程将fork(2)在所有活动线程中只有一个线程(在父进程中调用的线程),包括Go运行时使用的一些关键线程。基本上,这意味着您根本
无法期望子进程能够继续执行Go代码, 并且唯一明智的选择就是立即执行exec(2)。注意这syscall.ForkExec()就是应该使用的。

现在进一步考虑问题。我fork(2)想说,如今,直接调用唯一有用的是“尽力而为异步过程状态快照”,即Redis使用的那种。该技术依赖于以下事实:子进程从其父进程继承了所有内存数据页,但是OS使用写时复制技术无法真正复制所有数据,因此子进程可以坐在那里并保存所有数据结构到磁盘,而其父级却在自己的地址空间中修改它们。可以想到的其他所有用途都fork()意味着Instant
exec(),这就是exec.Command()et al的用途,那么为什么不使用它呢?



 类似资料:
  • 问题内容: 我正在尝试将对象保存到数据库中,但是抛出错误。 问题出在表格内,用一个复选框表示。如果未选中该复选框,则显然不传递任何内容。这就是错误被排除的地方。 我如何正确处理并捕获此异常? 该行是 问题答案: 使用MultiValueDict的方法。这在标准字典中也存在,并且是一种在不存在默认值的情况下获取值的方法。 通常,

  • 问题内容: 我正在尝试将对象保存到数据库中,但是抛出错误。 问题出在表格内,用一个复选框表示。如果未选中该复选框,则显然不传递任何内容。这就是错误被排除的地方。 我如何正确处理并捕获此异常? 该行是 问题答案: 使用t的get方法。这在标准字典中也存在,并且是一种在不存在默认值的情况下获取值的方法。 通常,

  • 我在spark streaming应用程序中看到一些失败的批处理,原因是与内存相关的问题,如 无法计算拆分,找不到块输入-0-1464774108087

  • 给定以下代码,如何将其简化为单个功能行? 这是我遇到的一个常见模式,我有一个流,我想过滤这个流,根据这个过滤器创建两个流,然后我可以对流a做一件事,对流B做另一件事。这是一个反模式,还是以某种方式得到支持?

  • 众所周知,Flink有两个核心API(数据流/数据集),但当我使用Flink Sql客户端提交作业时,我不需要选择流或批处理模式。所以,Flink SQL客户机是如何决定使用批处理模式和流模式的。我在官方文件中没有找到答案。所以,我想知道Flink SQL客户端如何区分批处理模式和流模式?

  • 由于预设审批人退出企业,导致模版自动停用时,可以在“异常处理”页面进行相应操作。