Почему в фильтре записываются не отфильтрованные байты?

Question

[gleendo]

Почему если после записи выводить записанные данные то оказывается что в конце записались не отфильтрованные байты (в данном случае нули). А если убрать вывод записанных в файл байтов, то метод работает корректно и в файл записываются все байты кроме нулей. Как вообще вывод данных, влияет на запись этих данных?

import java.io.*;
import java.util.Arrays;
import java.util.Random;

public class App {
    public static void main(String[] args) throws IOException {
        byte[] arr = new byte[10000];

        for (int i = 0; i < arr.length; i++) {
            arr[i] = (byte) (Math.random() * 2);
        }

        try (InputStream is = new ByteArrayInputStream(arr); OutputStream fos = new FileOutputStream("c://outfile.txt")) {
            long startTime = System.nanoTime();

            Filters.zeroFilter(is, fos, 1024);

            long deltaTime = System.nanoTime() - startTime;

            System.out.println("Скорость работы: " + deltaTime);
        }

        try (InputStream fis = new FileInputStream("c://outfile.txt")) { // Если убрать этот вывод, то все работает норм
            int value;

            while ((value = fis.read()) != -1) {
                System.out.print(value);
            }
        }
    }
}

class Filters {
    public static void zeroFilter(InputStream src, OutputStream dst, int buffSize)  throws IOException {
        try (OutputStream os = new BufferedOutputStream(dst)) {
            final byte STATE_ZERO = 0;
            final byte STATE_NUMBERS = 1;

            int count;
            byte[] buffer = new byte[buffSize];

            while ((count = src.read(buffer)) != -1) {
                byte state = STATE_ZERO;
                int fromIndex = -1;

                for (int index = 0; index < count; index++) {
                    byte elem = buffer[index];

                    switch (state) {
                        case STATE_ZERO:
                            if (elem == 0) {
                                state = STATE_ZERO;
                            } else {
                                state = STATE_NUMBERS;

                                fromIndex = index;
                            }

                            break;
                        case STATE_NUMBERS:
                            if (elem == 0) {
                                state = STATE_ZERO;

                                os.write(Arrays.copyOfRange(buffer, fromIndex, index));
                            } else {
                                state = STATE_NUMBERS;
                            }
                    }
                }

                if (state == STATE_NUMBERS) {
                    os.write(Arrays.copyOfRange(buffer, fromIndex, buffer.length));
                }
            }
        }
    }
}

Comments

[gleendo]

Ivan Sokolov: Разве это не сервис где задаешь вопрос и ждешь что тебе помогут с вопросом? У меня возникла проблема, я задал вопрос. Я про дебаггер могу отвечать на половину вопросов, а в другой половине посылать в гугл. Но тогда толку от это сервиса будет 0. В общем, если нечего дельного ответить, то лучше вообще ничего не пишите. Молча пройдите и все. Если вы не знаете как помочь, это не значит, что и другие такие же недалекие как вы.

[Денис Загаевский]

evg_: это не сервис, где за тебя отдебажат код, да.

[gleendo]

Ivan Sokolov: омг ясно все с вами. Проходите мимо.

Answer 1

[#алгоптимизируй #отботизируй]

1. С использованием BufferedOutputStream можно было уложиться в пару строчек.(zeroFilter)
2. Входные данные рандомные, выходной результат возможно тоже.( success/failed)

>>Как вообще вывод данных, влияет на запись этих данных
Никак в идеале.

Comments

[gleendo]

#алгоптимизируй #отботизируй У меня входные данные либо 0 либо 1. По идеи в файл должны записываться только единицы, фильтруя нули.
Я подумал, может быть, я когда начинаю записывать данные в файл, и тут же создаю еще один входной поток к этому файлу, начиная выводить все в консоль, возможно такое что проблема из за потоков?
Я создал 2 отдельных потока, и в них отдельно выполнял запись, а потом чтение из файла. Один поток ждал выполнения другого. Так все нормально работает.

И как написать фильтр в пару строк?!

package labs;

import java.io.*;
import java.util.Arrays;

public class App00 {
    public static void main(String[] args) throws Exception {
        Thread t0 = new Thread(() -> {
            byte[] arr = new byte[10000];

            for (int i = 0; i < arr.length; i++) {
                arr[i] = (byte) (Math.random() * 2);
            }

            try (InputStream is = new ByteArrayInputStream(arr); OutputStream fos = new FileOutputStream("c://outfile.txt")) {
                long startTime = System.nanoTime();

                Filters.zeroFilter(is, fos, 1024);

                long deltaTime = System.nanoTime() - startTime;

                System.out.println("Скорость работы: " + deltaTime);
            } catch (IOException ignore) {
                // NOP
            }
        });

        t0.start();
        t0.join();


        Thread t1 = new Thread(() -> {
            try (InputStream fis = new FileInputStream("c://outfile.txt")) {
                int value;

                while ((value = fis.read()) != -1) {
                    System.out.print(value + " ");
                }
            } catch (IOException ignore) {
                // NOP
            }
        });

        t1.start();
        t1.join();
    }
}

class Filters {
    public static void zeroFilter(InputStream src, OutputStream dst, int buffSize)  throws IOException {
        try (OutputStream os = new BufferedOutputStream(dst)) {
            final byte STATE_ZERO = 0;
            final byte STATE_NUMBERS = 1;

            int count;
            byte[] buffer = new byte[buffSize];

            while ((count = src.read(buffer)) != -1) {
                byte state = STATE_ZERO;
                int fromIndex = -1;

                for (int index = 0; index < count; index++) {
                    byte elem = buffer[index];

                    switch (state) {
                        case STATE_ZERO:
                            if (elem == 0) {
                                state = STATE_ZERO;
                            } else {
                                state = STATE_NUMBERS;

                                fromIndex = index;
                            }

                            break;
                        case STATE_NUMBERS:
                            if (elem == 0) {
                                state = STATE_ZERO;

                                os.write(Arrays.copyOfRange(buffer, fromIndex, index));
                            } else {
                                state = STATE_NUMBERS;
                            }
                    }
                }

                if (state == STATE_NUMBERS) {
                    os.write(Arrays.copyOfRange(buffer, fromIndex, buffer.length));
                }
            }
        }
    }
}

[#алгоптимизируй #отботизируй]

evg_: Внутри zeroFilter есть ошибка.
Если будет острая необходимость в консультации - контакты в профиле.