0

我正在使用多线程来计算图像。每个线程计算一条线，当一个线程已经在计算一条线时，下一个线程是否应该计算那条线之后的线。但我想确保每一行都只计算一次，为了做到这一点，我可以制作一个 System.out.println(CalculatedLineNumber) 并在文本文件中输出，这样当我用文本打开它时编辑器，我会直接查看打印的行数是否与文本文件上的行数相同。但是我该怎么做呢？这是我完成计算的 run() 方法的代码片段：

public void run() {

                int myRow;
                while ( (myRow = getNextRow()) < getHeight() ) {
                    image.setRGB(0, myRow, getWidth(), 1, renderLine(myRow), 0, 0);
                }
            }

有人告诉我，我应该使用 PrintWriter 和 flush() 或类似的东西，但我不知道如何使用它。有人可以帮我吗？（“myRow”是我想写在文本文件上的行号，每个人都在不同的行）

太感谢了！！

4

1 回答 1

1

我想确保每一行都只计算一次，

我建议您使用 aExecutorService并将每一行作为图像作业提交到线程池。请参阅底部的代码示例。如果你做对了，那么你就不必担心会有多少输出线。

我可以做一个System.out.println(CalculatedLineNumber)

我不太明白这样做的必要性。这是某种会计文件来帮助您确保所有图像都已处理吗？

有人告诉我应该使用 PrintWriter 和 flush()

你不需要flushaPrintWriter因为它已经在下面同步了。只需在每个作业结束时打印出结果，如果您向您提交了 X 行作业， threadPool那么您将有 X 行输出。

您需要做的就是使用PrintWriter：

PrintWriter printWriter = new PrintWriter(new File("/tmp/outputFile.txt"));
// each thread can do:
writer.println("Some sort of output: " + myRow);

下面是一些示例代码来展示如何使用ExecutorService线程池。

PrintWriter outputWriter = ...;
// create a thread pool with 10 workers
ExecutorService threadPool = Executors.newFixedThreadPool(10);
// i'm not sure exactly how to build the parameter for each of your rows
for (int myRow : rows) {
    // something like this, not sure what input you need to your jobs
    threadPool.submit(new ImageJob(outputWriter, myRow, getHeight(), getWidth()));
}
// once we have submitted all jobs to the thread pool, it should be shutdown
threadPool.shutdown();
...
public class ImageJob implements Runnable {
    private PrintWriter outputWriter;
    private int myRow;
    private int height;
    private int width;
    public MyJobProcessor(PrintWriter outputWriter, int myRow, int height,
            int width, ...) {
        this.outputWriter = outputWriter;
        this.myRow = myRow;
        this.height = height;
        this.width = width;
    }
    public void run() {
        image.setRGB(0, myRow, width, 1, renderLine(myRow), 0, 0);
        outputWriter.print(...);
    }
}
于 2012-06-11T19:36:58.180 回答