jjzjj

go - 坚持 Go 并发

coder 2024-07-10 原文

我似乎不知道下一步该做什么。我的目标是使用图像包中的 SubImage 函数从原始图像创建一个包含所有子图像的数组。我能够在 imageSplit() 函数中分割图像并通过 channel 传递给 imageReceiver() 函数。

我实际上在函数 imageReceiver() 中接收数据，但我不知道如何在从 imageSplit() 函数接收到所有图像后附加到数组并使用它。

// Partitions Image
func Partition(src image.Image) []image.Image {

    newImg := image.NewNRGBA64(src.Bounds())

    r := newImg.Rect
    dx, dy := r.Dx(), r.Dy()

   // partitionNum
   pNum := 3

    // partition x
    px, py := (dx / pNum), (dy / pNum)

    imgChan := make(chan image.Image)
    imgStorage := make([]image.Image, 0)

    for i := 1; i < pNum; i++ {
        for j := 1; j < pNum; j++ {
            startX, startY := ((px * i) - px), ((py * j) - py)
            endX, endY := (px * i), (py * j)

            go imageSplit(imgChan, newImg, startX, startY, endX, endY)
            go imageReceiver(imgChan)
        }
    }

    return imgStorage

}

// Creates sub-images of img
func imageSplit(imgChan chan image.Image, img *image.NRGBA64, startX, startY, endX, endY int) {
    r := image.Rect(startX, startY, endX, endY)
    subImg := img.SubImage(r)

    imgChan <- subImg
}

// Receive sub-image from channel
func imageReceiver(imgChan chan image.Image) {
    img := <-imgChan
    spew.Dump(img.Bounds())
}

我想创建一个全局 image.Image 数组，但我不确定这是否是“保存”所有子图像的正确方法。

我想这有点令人困惑的原因是因为这是我第一次在 Go 中处理并发。 感谢您的帮助:)

最佳答案

关于如何做到这一点有几个选项，但我想说你的基本问题是你的接收器不进行聚合，如果你改变它，它不会是线程安全的。

修改接收器以进行聚合的简单选择是在循环之前分配一个 Image 数组，并将指向它的指针传递给接收器方法，然后在读取时只使用 append这个 channel 。但是你会有一堆不同的 goroutines 争夺同一个数组的访问权。所以真的，你不希望聚合是多线程的。如果是，则需要锁定机制才能写入集合。

相反，你想在循环之后阻塞。最简单的方法就是将接收器的主体放在循环之后的内联中，例如；

imgs := []image.Image{}
img := <-imgChan
imgs = append(imgs, img)
spew.Dump(img.Bounds())

问题出在现实世界中，然后您的软件会阻塞在那条线上并且没有响应(无法死机或退出或任何其他方式)所以您通常会使用至少有 2 个 channel 的 channel 选择/cases，Partition 的调用者在需要退出时可以用来终止它的中止 channel ，以及从 imgChan 接收的 case。那看起来更像这样；

imgs := []image.Image{}

select {
    case img := <-imgChan
         imgs = append(imgs, img)
         spew.Dump(img.Bounds())
    case _ := <-abortChan:
        return MyCustomError();
    }

这使得您的聚合不是并发的，只有产生结果的工作，我个人认为这是更好的设计。我也可以解释如何锁定您的接收器方法，但我相信您可以找到大量互斥锁等示例。

关于go - 坚持 Go 并发，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/30062128/

goimageimgChanchannelgoroutine

有关go - 坚持 Go 并发的更多相关文章

  1. ruby-on-rails - 获取并发布相同匹配项的请求 - 2

    在我的路线文件中我有:match'graphs/(:id(/:action))'=>'graphs#(:action)'如果是GET请求(工作)或POST请求(不工作)，我想匹配它我知道我可以使用以下方法在资源中声明POST请求:post'/'=>:show,:on=>:member但是我怎样才能为比赛做到这一点呢？谢谢。 最佳答案 如果你同时想要POST和GETmatch'graphs/(:id(/:action))'=>'graphs#(:action)',:via=>[:get,:post]编辑默认值可以设置如下match'g

  2. ruby-on-rails - Textmate 'Go to symbol' 相当于 Vim - 2

    在Railcasts上，我注意到一个非常有趣的功能“转到符号”窗口。它像Command-T一样工作，但显示当前文件中可用的类和方法。如何在vim中获取它？ 最佳答案 尝试:helptags有各种程序和脚本可以生成标记文件。此外，标记文件格式非常简单，因此很容易将sed(1)或类似的脚本组合在一起，无论您使用何种语言，它们都可以生成标记文件。轻松获取标记文件(除了下载生成器之外)的关键在于格式化样式而不是实际解析语法。 关于ruby-on-rails-Textmate'Gotosymbol

  3. Ruby 并发/异步处理(简单用例) - 2

    我一直在研究ruby​​的并行/异步处理能力，并阅读了许多文章和博客文章。我查看了EventMachine、Fibers、Revactor、Reia等。不幸的是，我无法为这个非常简单的用例找到简单、有效(且非IO阻塞)的解决方案:File.open('somelogfile.txt')do|file|whileline=file.gets#(R)ReadfromIOline=process_line(line)#(P)Processthelinewrite_to_db(line)#(W)WritetheoutputtosomeIO(DBorfile)endend你看到了吗，我的小脚本正

  4. ruby-on-rails - 乘客并发连接错误 - 2

    我有生产服务器(Nginx+Passenger)。当我尝试从另一台计算机ab-n3-c3myhost.ru/时，我在我的nginxerror.log中收到此错误日志:[pid=21160thr=139775297914624file=ext/nginx/HelperAgent.cpp:584time=2011-08-3115:25:49.22]:UncaughtexceptioninPassengerServerclientthread:exception:Cannotreadresponsefrombackendprocess:Connectionresetbypeer(104)ba

  5. 设计一个亿级高并发系统架构 - 12306火车票核心场景DDD领域建模 - 2

    “架设一个亿级高并发系统，是多数程序员、架构师的工作目标。许多的技术从业人员甚至有时会降薪去寻找这样的机会。但并不是所有人都有机会主导，甚至参与这样一个系统。今天我们用12306火车票购票这样一个业务场景来做DDD领域建模。”开篇要实现软件设计、软件开发在一个统一的思想、统一的节奏下进行，就应该有一个轻量级的框架对开发过程与代码编写做一定的约束。虽然DDD是一个软件开发的方法，而不是具体的技术或框架，但拥有一个轻量级的框架仍然是必要的，为了开发一个支持DDD的框架，首先需要理解DDD的基本概念和核心的组件。一.什么是领域驱动设计(DDD)首先要知道DDD是一种开发理念，核心是维护一个反应领域概

  6. ruby - 并发::Promise.all？不起作用 - 2

    在执行所有promise后，我正在尝试进行一些计算。但是proc从不调用:cbr_promise=Concurrent::Promise.execute{CbrRatesService.call}bitfinex_promise=Concurrent::Promise.execute{BitfinexService.call}proc=Proc.newdoputs10endConcurrent::Promise.all?([cbr_promise,bitfinex_promise]).then{proc}使用concurrent-ruby制作gem。例如，我是否应该创建一个每100毫秒

  7. ruby-on-rails - 用于 Ruby 的 vim 中的全局 "Go to definition"？ - 2

    自97年以来我一直在使用vi/vim进行各种快速编辑和管理任务，但最近才考虑使用它来替换Netbeans作为我选择的ruby​​编辑器。我发现一件事在Netbeans和Eclipse中非常有用的是Ctrl+Click“转到定义”功能，您可以在其中按住Ctrl键并单击一个类或方法，然后它将带您了解定义。现在，我玩过丰富的ctags和rails.vim，而且很接近，但没有雪茄。这就是我想要的:默认情况下在Netbeans和Eclipse中，您可以在本地rails中按住ctrl并单击本地方法或类项目，但你也可以ctrl+click定义在gems或用Ruby编写的系统库。以Netbeans为例

  8. ruby - 处理并发 ruby​​ 线程池中的异常 - 2

    如何处理并发ruby​​线程池中的异常(http://ruby-concurrency.github.io/concurrent-ruby/file.thread_pools.html)？例子:pool=Concurrent::FixedThreadPool.new(5)pool.postdoraise'somethinggoeswrong'end#howtorescuethisexceptionhere更新:这是我的代码的简化版本:defprocesspool=Concurrent::FixedThreadPool.new(5)products.eachdo|product|new_

  9. ruby - 如何限制同一 Ruby 脚本的并发实例？ - 2

    在Ruby1.9.x中，不允许我的Ruby脚本再次运行或等待前一个实例完成的简单方法是什么？**我希望避免困惑的文件锁定或进程表检查。有没有类似globalmutex的东西或信号量已经在核心？我研究了原生Mutex但这似乎只适用于一个Ruby进程内的线程，而不适用于不同进程。**稍后我可能会添加超时功能，或者限制为N个实例，或者希望使用多个全局锁(每个系统范围的资源一个，最多只能有一个实例)。 最佳答案 这段非常短的代码将卡住在原地，直到/tmp中以您的脚本命名的锁定文件被独占锁定:File.open("/tmp/#{File.ba

  10. ruby - 了解赛璐珞并发 - 2

    以下是我的赛璐珞代码。client1.rb2个客户之一。(我将其命名为客户端1)client2.rb2个客户中的第2个。(命名为客户端2)备注:上述2个客户端之间的唯一区别是传递给服务器的文本。即('client-1'和'client-2'分别)针对以下2个服务器(一次一个)测试这2个客户端(通过并排运行)。我发现非常奇怪的结果。server1.rb(取自celluloid-zmq的README.md的基本示例)将其用作上述2个客户端的示例服务器导致任务的并行执行。输出rubyserver1.rbReceivedat04:59:39PMandmessageisclient-1Going

随机推荐