4

我正在尝试多线程一些 OpenCV4Android 代码。我将 432x432 图像分成 9 个 144x144 段，并将每个段传递给不同的线程： 

Thread[] threads = new Thread[9];
for (int i = 0; i < 3; i++) {
    for (int j = 0; j < 3; j++) {
        threads[3*i+j] = new Thread(new MyThread(image.rowRange(144*i, 144*(i+1)).colRange(144*j, 144*(j+1))));
        threads[3*i+j].start();
    }
}

for (Thread thread : threads) try {thread.join();} catch (InterruptedException e) {};

这是线程类：

public class MyThread implements Runnable {
    final Mat block;

    public MyThread(Mat block) {
        this.block = block;
    }

    public void run() {
        /* do image processing on block */
        Mat kernel = Imgproc.getStructuringElement(Imgproc.MORPH_ELLIPSE, new Size(19,19));
        Mat closed = new Mat();
        Imgproc.morphologyEx(block, closed, Imgproc.MORPH_CLOSE, kernel);
        Core.divide(block, closed, block, 1, CvType.CV_32F);
        Core.normalize(block, block, 0, 255, Core.NORM_MINMAX);
        block.convertTo(block, CvType.CV_8UC1);     
        Imgproc.threshold(block, block, -1, 255, Imgproc.THRESH_BINARY_INV+Imgproc.THRESH_OTSU);
    }
}

我有两个问题：

  1. 尽管线程正在正确修改各个块，但修改并未显示在最终图像中。如果按值传递给线程，这将是有意义Mat block的，但 Java 应该将其引用传递给线程。

  2. 运行时比非线程代码长 - 在我的模拟器中，它从 ~1200 上升到 ~1500 毫秒。这是模拟器的问题，还是由于某种原因多线程在这里是一个非常糟糕的主意？

4

3 回答 3

3

我没有使用 OpenCV 的经验，所以我将只解决第二个问题。

线程需要一个 CPU 才能运行（或一个充当虚拟 CPU 的核心）。因此，您将永远不会同时运行比设备中可用的实际内核数更多的线程。

假设您有一个具有 2 个内核的设备，并且您将工作分成 9 个线程。最终结果是 9 个线程中只有 2 个线程将同时运行，而其余 7 个线程将在队列中等待轮到它们获得 CPU。

由于线程创建和切换是有成本的，因此整体性能结果会比只有 2 个线程更差。

如果出于性能原因在线程之间拆分工作，请不要使线程数超过设备中的内核数。

我相信市场上的大多数设备都仅限于 1 或 2 个核心......

问候

于 2012-12-10T01:21:31.337 回答
1

第一个问题是由block本节中将 Mat 转换为不同类型引起的： 

Core.divide(block, closed, block, 1, CvType.CV_32F);
Core.normalize(block, block, 0, 255, Core.NORM_MINMAX);
block.convertTo(block, CvType.CV_8UC1);

我不确定为什么这应该是一个问题，但我通过将中间浮点矩阵存储在closed其中并将最终答案放回中来修复它block：

Core.divide(block, closed, closed, 1, CvType.CV_32F);
Core.normalize(closed, block, 0, 255, Core.NORM_MINMAX, CvType.CV_8U);
于 2012-12-11T02:17:51.173 回答
0

Luis 解决了第二个问题。我认为第一个问题是因为你处理了一个新的 Mat 到线程，对新 Mat 的修改不会影响旧的。

我找到了 rowRange 的源代码，有一些本机代码，但显然它创建了一个新对象。

 public Mat rowRange(int startrow, int endrow)
 {

     Mat retVal = new Mat(n_rowRange(nativeObj, startrow, endrow));

     return retVal;
 }
于 2012-12-10T03:07:51.033 回答