java - 多线程java图像阈值处理-6ren

java - 多线程java图像阈值处理

转载作者：行者123 更新时间：2023-11-30 08:08:50

我有一个学校项目，我们应该使用并行编程来使某些算法运行得更快。例如，我选择了图像阈值。

所以我创建了Java程序，它正常执行(加载图像，循环所有像素，计算阈值，再次循环所有像素并设置黑色或白色，如果它大于或小于阈值)。在我的笔记本上，处理大约 4000x3000 的图片大约需要 5 秒，处理 11500x11500 的图像大约需要 49 秒。

然后我创建了另一个程序，它应该使用线程，以使它们循环更快地完成。

现在我正在创建 4 个线程，每个线程处理 1/4 的图像。首先，他们将阈值添加到同步数组列表中，所有这些都完成后，我计算阈值。然后我创建另外 4 个线程，它们再次处理每个图像的 1/4，并将图像设置为黑色或白色。

这花了我 12 秒来处理 4000x3000 的图像，并抛出 java.lang.OutOfMemoryError: Java 堆空间(在所有线程中)和 11500x11500 的图像。

 public class PprPrahovaniParalelne{

    /**
     * @param args the command line arguments
     */
    public static void main(String[] args) throws IOException {
        final Threshold image = new Threshold(nactiObrazek("ryba.jpg"));


        final int width = image.getImage().getWidth();
        final int height = image.getImage().getHeight();


        Thread t1 = new Thread(){
            int threshold;
            public void run(){
                System.out.println("Thread 1 - Started");
                for(int y = 0; y < height/4;y++){
                    for(int x = 0; x < width;x++){
                        Color color = new Color(image.getImage().getRGB(x,y));
                        threshold = (color.getRed()+color.getGreen()+color.getBlue())/3;
                        image.addThreshold(threshold); 
                    }
                }
                System.out.println("Thread 1 - finished");
            }
        };

        Thread t2 = new Thread(){
            int threshold;
            @Override
            public void run(){
                for(int y = height/4; y < height/4*2;y++){
                    for(int x = 0; x < width;x++){
                        Color barva = new Color(image.getImage().getRGB(x,y));
                        threshold = (barva.getRed()+barva.getGreen()+barva.getBlue())/3;
                        image.addThreshold(threshold); 
                    }
                }
                System.out.println("Thread 2 - finished");
            }
        };

        Thread t3 = new Thread(){
            int threshold;
            @Override
            public void run(){
                for(int y = height/4*2; y < height/4*3;y++){
                    for(int x = 0; x < width;x++){
                        Color barva = new Color(image.getImage().getRGB(x,y));
                        threshold = (barva.getRed()+barva.getGreen()+barva.getBlue())/3;
                        image.addThreshold(threshold); 
                    }
                }
                System.out.println("Thread 3 - finished");
            }
        };

        Thread t4 = new Thread(){
            int threshold;
            @Override
            public void run(){
                for(int y = height/4*3; y < height;y++){
                    for(int x = 0; x < width;x++){
                        Color barva = new Color(image.getImage().getRGB(x,y));
                        threshold = (barva.getRed()+barva.getGreen()+barva.getBlue())/3;
                        image.addThreshold(threshold); 
                    }
                }
                System.out.println("Thread 4 - finished");
            }
        };

        t1.start();
        t2.start();
        t4.start();
        t3.start();

        try{
            t1.join();
            t2.join();
            t3.join();
            t4.join();
        }catch(InterruptedException e){
            e.printStackTrace();
        }


        image.countThreshold();
        System.out.println("Threshold je: " + image.getThreshold());

        Thread t5 = new Thread(){
            Color cerna = new Color(255,255,255);
            Color bila = new Color(0,0,0);
            int threshold;
            @Override
            public void run(){
                for(int y = 0; y < height/4;y++){
                    for(int x = 0; x < width;x++){
                        Color barva = new Color(image.getImage().getRGB(x,y));
                        threshold = (barva.getRed()+barva.getGreen()+barva.getBlue())/3;
                        if(threshold > image.getThreshold()){
                            image.getImage().setRGB(x, y, cerna.getRGB());
                        }else{
                            image.getImage().setRGB(x, y, bila.getRGB());
                        }
                    }
                }                
                System.out.println("Thread 5 - finished");
            }
        };

        Thread t6 = new Thread(){
            Color cerna = new Color(255,255,255);
            Color bila = new Color(0,0,0);
            int threshold;
            @Override
            public void run(){
                for(int y = height/4; y < height/4*2;y++){
                    for(int x = 0; x < width;x++){
                        Color color = new Color(image.getImage().getRGB(x,y));
                        threshold = (color.getRed()+color.getGreen()+color.getBlue())/3;
                        if(threshold > image.getThreshold()){
                            image.getImage().setRGB(x, y, cerna.getRGB());
                        }else{
                            image.getImage().setRGB(x, y, bila.getRGB());
                        }
                    }
                }                
                System.out.println("Thread 6 - finished");
            }
        };

        Thread t7 = new Thread(){
            Color cerna = new Color(255,255,255);
            Color bila = new Color(0,0,0);
            int threshold;
            @Override
            public void run(){
                for(int y = height/4*2; y < height/4*3;y++){
                    for(int x = 0; x < width;x++){
                        Color color = new Color(image.getImage().getRGB(x,y));
                        threshold = (color.getRed()+color.getGreen()+color.getBlue())/3;
                        if(threshold > image.getThreshold()){
                            image.getImage().setRGB(x, y, cerna.getRGB());
                        }else{
                            image.getImage().setRGB(x, y, bila.getRGB());
                        }
                    }
                }                
                System.out.println("Thread 7 - finished");
            }
        };

        Thread t8 = new Thread(){
            Color cerna = new Color(255,255,255);
            Color bila = new Color(0,0,0);
            int threshold;
            @Override
            public void run(){
                for(int y = height/4*3; y < height;y++){
                    for(int x = 0; x < width;x++){
                        Color barva = new Color(image.getImage().getRGB(x,y));
                        threshold = (barva.getRed()+barva.getGreen()+barva.getBlue())/3;
                        if(threshold > image.getThreshold()){
                            image.getImage().setRGB(x, y, cerna.getRGB());
                        }else{
                            image.getImage().setRGB(x, y, bila.getRGB());
                        }
                    }
                }                
                System.out.println("Thread 8 - finished");
            }
        };

        t5.start();
        t6.start();
        t7.start();
        t8.start();

        try{
            t5.join();
            t6.join();
            t7.join();
            t8.join();
        }catch(InterruptedException e){
            e.printStackTrace();
        }

        File hotovo = new File("ryba_prahovanej.jpg");
        ImageIO.write(image.getImage(), "jpg", hotovo);

    }


    public static BufferedImage nactiObrazek(String nazev){
        BufferedImage img = null;
        try {
            img = ImageIO.read(new File(nazev));
        } catch (IOException e) {
        }
        return img;        
    }    
}

和阈值类:

public class Threshold {
    private BufferedImage image;
    final private List<Integer> list;
    private int threshold;

    public int getThreshold() {
        return threshold;
    }

    public List<Integer> getList(){
        return list;
    }

    public Threshold(BufferedImage obrazek) {
        this.list = Collections.synchronizedList(new ArrayList<Integer>());
        this.image = obrazek;
    }

    public void setObrazek(BufferedImage obrazek){
        this.image = obrazek;
    }

    public BufferedImage getImage(){
        return this.image;
    }

    public void addThreshold(int threshold){
        list.add(threshold);
    }

    public void countThreshold(){
        long sum = 0;
        for (Iterator<Integer> it = list.iterator(); it.hasNext();) {
            int item = it.next();
            sum += item;
        }
        this.threshold = (int) (sum/list.size());    
    }
}

那么为什么多线程时会变慢呢？除了列表之外，我不会在这里同步任何内容，因为线程不应该在像素数组中使用相同的索引。

此处的分析器图片:

系列: Serial

并行: Paralel

最佳答案

在这种并行化情况下，您需要考虑一些事情。

您的代码仅对图像进行异步处理(计算阈值并创建阈值图像)，但您的图像 IO(写入)会被阻止，直到所有线程完成处理。
另一个更重要的因素是您是如何提出 4 线程解决方案的。您选择 4 个线程作为理想线程数的原因是什么？在像您这样的 CPU 和内存密集型多线程程序中，理想的线程数 = CPU 数量 + 1。拥有更多线程并不会使程序执行得更快，事实上反而会降低性能。
图像处理当然是内存密集型的，当运行带有大图像的程序时，您需要增加堆空间。

请考虑上述内容。

编辑

您可以首先使代码更具可读性并减少代码重复。您可以利用 CyclicBarrier 来实现并行任务的顺序执行。

import java.awt.image.*;
import java.io.*;
import java.awt.*;
import javax.imageio.*;
import java.util.concurrent.*;

public class PprPrahovaniParalelne {

    /**
     * @param args the command line arguments
     */
    public static void main(String[] args) throws IOException {
        final Threshold image = new Threshold(nactiObrazek("DSC03691.jpg"));


        final int width = image.getImage().getWidth();
        final int height = image.getImage().getHeight();

    final int nCpu = Runtime.getRuntime().availableProcessors() + 1;

    ExecutorService threadPool = Executors.newFixedThreadPool(nCpu);

    System.out.println("Number of CPUs : "+nCpu);

    CyclicBarrier cyclicBarrier = new CyclicBarrier(4, new Runnable() {
            private int count = 1;

            public void run() {
                if(count == 1) {
            image.countThreshold();
                System.out.println("Threshold je: " + image.getThreshold());

        } else {
            try {
                File hotovo = new File("ryba_prahovanej.jpg");
                    ImageIO.write(image.getImage(), "jpg", hotovo);
            } catch(IOException e) {
                System.err.println("Error while writing : " + e);
            }
            threadPool.shutdownNow();
        }
        count++;
            }
        });

    threadPool.submit(new ImageProcessingTask(0, height/4, width, image, cyclicBarrier));
    threadPool.submit(new ImageProcessingTask(height/4, height/4*2, width, image, cyclicBarrier));
    threadPool.submit(new ImageProcessingTask(height/4*2, height/4*3, width, image, cyclicBarrier));
    threadPool.submit(new ImageProcessingTask(height/4*3, height, width, image, cyclicBarrier));

    }


    public static BufferedImage nactiObrazek(String nazev){
        BufferedImage img = null;
        try {
            img = ImageIO.read(new File(nazev));
        } catch (IOException e) {
        }
        return img;        
    }    
}

class ImageProcessingTask implements Runnable {

    private int start;
    private int height;
    private int width;
    private Threshold image;
    private CyclicBarrier barrier;

    public ImageProcessingTask(int start, int height, int width, Threshold image, CyclicBarrier barrier) {
        this.start = start;
        this.height = height;
        this.width = width;
        this.image = image;
        this.barrier = barrier;
    }

        public void run(){
                int threshold;
                System.out.println(Thread.currentThread().getName()+" - Started");
                for(int y = start; y < height;y++){
                    for(int x = 0; x < width;x++){
                        Color color = new Color(image.getImage().getRGB(x,y));
                        threshold = (color.getRed()+color.getGreen()+color.getBlue())/3;
                        image.addThreshold(threshold); 
                    }
                }
        try {
            int count = barrier.await();
            if(count == 0) {
                barrier.reset();
                System.out.println("Resetting Cyclic Barrier");
            }
        } catch(InterruptedException e) {
            Thread.currentThread().interrupt();
        } catch(Exception e) {
            e.printStackTrace();
        }
        Color cerna = new Color(255,255,255);
                Color bila = new Color(0,0,0);
        for(int y = start; y < height;y++){
                    for(int x = 0; x < width;x++){
                        Color barva = new Color(image.getImage().getRGB(x,y));
                        threshold = (barva.getRed()+barva.getGreen()+barva.getBlue())/3;
                        if(threshold > image.getThreshold()){
                            image.getImage().setRGB(x, y, cerna.getRGB());
                        }else{
                            image.getImage().setRGB(x, y, bila.getRGB());
                        }
                    }
                }    
        try {
            barrier.await();
        } catch(InterruptedException e) {
            Thread.currentThread().interrupt();
        } catch(Exception e) {
            e.printStackTrace();
        }
                System.out.println(Thread.currentThread().getName()+" - finished");

    }
}

关于java - 多线程java图像阈值处理，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/30707643/

文章推荐： java - 了解Dagger 2应用架构

文章推荐： php - 数据不通过 AJAX

文章推荐： java - 以类为键的 TreeMap

文章推荐： java - 如何使用 Odf Toolkit 从 odt 文档中提取图像？

javascript - 图像->JSON->.Net 图像
我正在尝试学习 Knockout 并尝试创建一个照片 uploader 。我已成功将一些图像存储在数组中。现在我想回帖。在我的 knockout 码(Javascript)中，我这样做: 我在 Jav
php - 如何在mysql中添加文本+图像+文本+图像+ ...？
我正在使用 php 编写脚本。我的典型问题是如何在 mysql 中添加一个有很多替代文本和图像的问题。想象一下有机化学中具有苯结构的描述。最有效的方法是什么？据我所知，如果我有一个图像，我可以在数据
html - Bootstrap 图像/按钮/图像
我在两个图像之间有一个按钮，我想将按钮居中到图像高度。有人可以帮帮我吗？ Entrar
javascript - 从中心点旋转全尺寸 Canvas 图像，而不移动其他 Canvas 图像
下面的代码示例可以在这里查看 - http://dev.touch-akl.com/celebtrations/ 我一直在尝试做的是在 Canvas 上绘制 2 个图像(发光，然后耀斑。这些图像的链接
javascript - 为什么相同的 JS 代码不适用于第二个帖子/图像，但适用于第一个帖子/图像？
请检查此https://jsfiddle.net/rhbwpn19/4/ 图像预览对于第一篇帖子工作正常，但对于其他帖子则不然。我应该在这里改变什么？ function readURL(input)
javascript - HTML Canvas 图像 - 在页面中绘制多 Canvas 图像
我对 Canvas 有疑问。我可以用单个图像绘制 Canvas ，但我不能用单独的图像绘制每个 Canvas 。- 如果数据只有一个图像，它工作正常，但数据有多个图像，它不工作你能帮帮我吗？ va
ios - 查找指定文件的扩展文件类型(JPEG 图像、TIFF 图像、...) objective c
我的问题很简单。如何获取 UIImage 的扩展类型？我只能将图像作为 UIImage 而不是它的名称。图像可以是静态的，也可以从手机图库甚至文件路径中获取。如果有人可以为此提供一点帮助，将不胜感激。
image-processing - 如何将 SVG 图像 "paths"转换为单独的 PNG 图像？
我有一个包含 67 个独立路径的 SVG 图像。是否有任何库/教程可以为每个路径创建单独的光栅图像(例如 PNG)，并可能根据路径 ID 命名它们？最佳答案谢谢大家。我最终使用了两个答案的组合。
javascript - 使一个(图像)向右移动并旋转 45 度，同时将鼠标悬停在另一个(图像)上
我想将鼠标悬停在一张图片(音乐专辑)上，然后播放一张唱片，所以我希望它向右移动并旋转一点，当它悬停时我希望它恢复正常动画片。它已经可以向右移动，但我无法让它随之旋转。我喜欢让它尽可能简单，因为我不是编
ios - Retina iOS 设备不显示@2X 图像，它显示 1X 图像
Retina iOS 设备不显示@2X 图像，它显示 1X 图像。我正在使用 Xcode 4.2.1 Build 4D502，该应用程序的目标是 iOS 5。我创建了一个测试应用(主/细节)并添加
javascript - 如何将 HTML CSS 图像 slider 转换为 Angular 图像 slider ？
我正在尝试从头开始以 Angular 实现图像 slider ，并尝试复制 w3school基于图像 slider 。下面我尝试用 Angular 实现，谁能指导我如何使用 Angular 实现？
c++ - 如何从 opencv 中的 RGB 图像(3 channel 图像)访问图像数据
我正在尝试获取图像的图像数据，其中 w= 图像宽度，h = 图像高度 for (int i = x; i imageData[pos]>0) //Taking data (here is the pr
php - HTML (或 JS 图像)与通过 PHP 的内联图像(base64_encoded 图像)
我的网页最初通过在 javascript 中动态创建图像填充了大约 1000 个缩略图。由于权限问题，我迁移到 suPHP。现在不用标准标签本身我正在通过这个 php 脚本进行检索 $file
python - 将 Python Opencv 图像(numpy 数组)转换为 PyQt QPixmap 图像
我正在尝试将 python opencv 图像转换为 QPixmap。我按照指示显示Page Link我的代码附在下面 img = cv2.imread('test.png')[:,:,::1]/2
python - OpenCV 将图像读取为 3 channel 图像，而 PIL 将图像读取为 1 channel 图像
我试图在这个 Repository 中找出语义分割数据集的 NYU-v2 . 我很难理解图像标签是如何存储的。例如，给定以下图像: 对应的标签图片为: 现在，如果我在 OpenCV 中打开标签图像，
java - 如何循环 8*1 svg 图像(由 java 生成)以获得 8*8 svg 图像？
import java.util.Random; class svg{ public static void main(String[] args){ String f="\"
Android自定义画笔图案/图像
我有一张 8x8 的图片。 (位图 - 可以更改) 我想做的是能够绘制一个形状，给定一个 Path 和 Paint 对象到我的 SurfaceView 上。目前我所能做的就是用纯色填充形状。我怎样才
HTML 图像
要在页面上显示图像，你需要使用源属性（src）。src 指 source 。源属性的值是图像的 URL 地址。定义图像的语法是：在浏览器无法载入图像时，替换文本属性告诉读者她们失去的信息。此
图像&视频编辑工具箱MMEditing安装及使用示例(Inpainting)
**MMEditing是基于PyTorch的图像&视频编辑开源工具箱，支持图像和视频超分辨率(super-resolution)、图像修复(inpainting)、图像抠图(matting)、
来自资源文件的 Qt 图像
我正在尝试通过资源文件将图像插入到我的程序中，如下所示: green.png other files 当我尝试使用 QImage 或 QPixm

行者123

个人简介

我是一名优秀的程序员,十分优秀！

作者热门文章

滴滴打车优惠券免费领取

全站热门文章

首页

博学

6Ren·AI

商城

java - 多线程java图像阈值处理