Java HashMap иногда возвращает неправильное значение в некоторых потоках

Question

Обновление: Это была статика, скрытая глубоко в каком-то коде, где она использовалась всего лишь для пары инструкций. Спасибо всем за предложения.

Мы не используем один HashMap для потоков (да, это плохо по многим причинам). Каждый поток имеет свой собственный HashMap.

У нас есть класс, который выходит из Thread. В Thread.run () мы создаем HashMap, устанавливаем в нем пару ключ / значение и передаем этот HashMap методу. Этот метод извлекает значение из HashMap, вставляет его в строку и возвращает строку.

Иногда возвращаемая строка имеет другое значение (все еще в Thread.run ()). Это происходит только на оборудовании с 3+ физическими ядрами. И это происходило только дважды (прежде чем мы добавили запись в журнал, чтобы, конечно, помочь нам точно определить, что происходит).

Любая идея, почему это произойдет.

Обновление: вот полный код. ProcessTxt - это то, что извлекает значение из HashMap и помещает его в строку.

import java.io.*;
import java.util.HashMap;

import junit.framework.TestCase;
import net.windward.datasource.dom4j.Dom4jDataSource;
import net.windward.xmlreport.ProcessReport;
import net.windward.xmlreport.ProcessTxt;

/**
 * Test calling from multiple threads
 */
public class TestThreads extends TestCase {

    private static String path = ".";

    // JUnit stuff
    public TestThreads(String name) {
        super(name);
    }

    // Get logging going - called before any tests run
    protected void setUp() throws Exception {
        ProcessReport.init();
    }

    // this is not necessary - called after any tests are run
    protected void tearDown() {
    }

    private static final int NUM_THREADS = 100;

    private boolean hadWithVarError = false;


    /**
     * Test that each thread has unique variables.
     */
    public void testRunReportsWithVariables() throws Exception {

        // run 10 threads
        ReportThreadWithVariables[] th = new ReportThreadWithVariables[NUM_THREADS];
        for (int ind = 0; ind < NUM_THREADS; ind++) {
            th[ind] = new ReportThreadWithVariables(this, ind);
            th[ind].setName("Run " + ind);
        }
        for (int ind = 0; ind < NUM_THREADS; ind++)
            th[ind].start();

        boolean allDone = false;
        while (!allDone) {
            Thread.sleep(100);
            allDone = true;
            for (int ind = 0; ind < NUM_THREADS; ind++)
                if (th[ind].isAlive())
                    allDone = false;
        }

        assertTrue(!hadWithVarError);
    }

    public static class ReportThreadWithVariables extends Thread {

        private TestThreads obj;
        private int num;

        public ReportThreadWithVariables(TestThreads tt, int num) {
            obj = tt;
            this.num = num;
        }

        public void run() {

            try{
                System.out.println("starting " + num);
                ByteArrayOutputStream out = new ByteArrayOutputStream();
                ProcessTxt pt = new ProcessTxt(new FileInputStream(new File(path, "Thread_Test.docx")), out);

                pt.processSetup();

                // don't use order1.xml, but need a datasource.
                Dom4jDataSource datasource = new Dom4jDataSource(new FileInputStream(new File(path, "order1.xml")));
                HashMap map = new HashMap();
                map.put("num", new Integer(num));
                datasource.setMap(map);
                pt.processData(datasource, "");

                pt.processComplete();
                String result = out.toString().trim();
                System.out.println("complete " + num + ", result = " + result);

                String expected = "Number: " + num;
                if (!result.equals( expected ))
                    obj.hadWithVarError = true;
                assertEquals(expected, result);
            } catch (Throwable e) {
                obj.hadWithVarError = true;
                e.printStackTrace();
            }

        }
    }
}

(изменить в коде формата)

Answer 1

Учитывая отсутствие кода и основываясь исключительно на том, что было написано, я собираюсь предположить, что что-то есть staticТо есть где-то вдоль строки в / записывается статический элемент.

Answer 2

num не является изменяемым, а другие переменные (string, map) являются локальными, поэтому ReportThreadWithVariables выглядит поточно-ориентированным.Мне кажется, что проблема в вызовах внешних объектов, а не в том, что вы отправили.Задокументированы ли используемые вами классы как безопасные для потоков?

Например, в Javadoc метода processData указано, что его нельзя вызывать несколько раз для одного и того же источника данных, который вы, похоже, делаете.(то же имя файла).

ps: (не связано) вы можете использовать CountDownLatch вместо цикла while.