我想创建一个简单的应用程序，它将连续读取一个应用程序的输出，对其进行处理并将处理后的输出写入标准输出。这个应用程序可以在一秒钟内产生大量数据，接下来会静默几分钟。问题是我的数据处理算法很慢，所以主循环被阻塞了。当循环被阻塞时，我正在丢失此时到来的数据。cmd:=exec.Command("someapp")stdoutPipe,_:=cmd.StdoutPipe()stdoutReader:=bufio.NewReader(stdoutPipe)gofunc(){bufioReader:=bufio.NewReader(stdoutReader)for{output,_,err:=bu

不知怎的，我不敢相信我是第一个遇到这个问题的人(我不想相信我是唯一一个愚蠢到不能直接看到解决方案的人)，但我的搜索功能不是足够强大。我经常遇到这样一种情况，需要一个接一个地执行一些耗时的步骤。工作流程看起来像vardata=DataGetter.GetData();varprocessedData=DataProcessor.Process(data);varuserDecision=DialogService.AskUserAbout(processedData);//...我不想在每一步都阻塞UI，所以每个方法都会立即返回，并在完成后引发一个事件。现在欢闹接踵而至，因为上面的代码块

我有基类DataProcessor。它是某些坐标系中位置计算器的基类。因此，例如，它可以有如下后代:SphericDataProcessor、CartesianDataProcessor。有基类CookedDataCatalogue，它是一些对象位置容器的基类。所以每个DataProcessor都应该能够将其数据放入每个CookedDataCatalogue。我可以想象这样的事情:classCookedDataCatalogue{virtualvoidTransform(DataProcessor*dp)=0;virtualvoidPutData(???)=0;}classCooked