Блог

Сомневаетесь в многопоточности. Ниже приведена моя основная программа для доступа к файлу, я создаю 10 потоков для доступа к объекту.

 public class CallTest {
    public static void main(String[] args) throws Exception {
        Test t = new Test();
        for (int i = 0; i < 10; i  ) {
            Thread t1 = new Thread(t);

            t1.start();

        }

    }
}
  

Ниже приведена моя программа для чтения данных из файла.

 public class Test implements Runnable {
    static int i;
    public void run() {
        try {
            i  ;
            System.out.println("@@@@Count"   i);
            print();
        } catch (Exception e) {}
    }

    public void print() {
        try {
            StringBuilder bufData = new StringBuilder();
            File fileTest = new File("D:\Work\i466477");
            BufferedReader bufferedReader1 = new BufferedReader(new FileReader(
                    fileTest));
            String strRecord = new String();
            while ((strRecord = bufferedReader1.readLine()) != null) {
                bufData.append(strRecord);
                bufData.append("r");
                bufData.append("n");
            }
            bufferedReader1.close();
            System.out.println("########");
            System.out.println(bufData);

        } catch (Exception exe) {
            System.out.println(exe);
        }
    }
}
  

Здесь я мог видеть, что код в while по умолчанию синхронизирован, BufferedReader потокобезопасен или потому, что у каждого потока будет своя копия StringBuilder и BufferedReader ? Я мог видеть, что содержимое прочитано и записано правильно.

Нет, этот код не будет синхронизирован по умолчанию. Каждый из нескольких потоков может находиться в while цикле одновременно. «Синхронизировано» — это не то же самое, что «работает без каких-либо проблем» — вы думали, что это было синхронизировано только потому, что у вас не было никаких проблем? В Java synchronized речь идет о том, чтобы разрешить только одному потоку выполнять определенные критические фрагменты кода одновременно по отношению к конкретному монитору.

Кстати, обратите внимание, что ваш доступ к i в run методе небезопасен. Вы также должны закрыть BufferedReader в finally блоке и избежать перехвата Exception . Наконец, ваше назначение new String() to strRecord для начала бессмысленно. Надеюсь, это просто ошибки из-за того, что это тестовый код, но о них стоит знать.

На самом деле System.out.println синхронизирован. Попробуйте это снова без них.

У каждого потока есть свой собственный StringBuilder, BufferedReader и FileReader (и файловый дескриптор уровня операционной системы), поэтому на этом уровне не будет никаких помех. (Ни один из этих классов не является потокобезопасным, но экземпляры ограничены потоками, так что это не имеет значения.)

Во время записи методы PrintWriter.print(...) и PrintWriter.println(...) синхронизированы, и это объясняет, почему вы не видите выходных данных от отдельных вызовов println, смешанных вместе. (PrintWriter потокобезопасен… и должно быть.)

Примечание: если вы изменили свой код, включив номер потока в каждую напечатанную строку, вы можете иногда видеть, что выходные данные отображаются в неожиданном порядке. Отдельные вызовы потокобезопасного метода для одного и того же объекта (PrintWriter) не обязательно выполняются в порядке «первым пришел, первым обслужен».

Код, который обновляет статическую переменную, i не является потокобезопасным и может время от времени выдавать неожиданные (неправильные) результаты… в зависимости от того, какое оборудование / JVM вы используете. Вам следует либо выполнить обновление в synchronized static методе, либо заменить i на AtomicInteger .

Локальные переменные ограничены потоком. Но неатомные операции (например, i ) со статической переменной i не являются потокобезопасными.

bufferreader и stringbuilder не являются общими для потоков, поэтому их использование потокобезопасно.

StringBuffer в определенной степени потокобезопасен, поскольку все его методы синхронизированы. BufferedReader не является потокобезопасным.