java - マルチスレッドデータベースアプリケーションの実行中に java.lang.NullPointerException が発生する

Question

複数のスレッドを作成し、データベースの同じテーブルをクエリするマルチスレッドアプリケーションの作成

次の形式の入力 xml ファイルがあるとします。

<transliteration>
<element>
    <source>about us</source>
</element>
</transliteration>

アプリケーションは複数のファイルを読み取り、xml ファイルごとに 1 つずつ複数のスレッドを作成し、出力は次の形式の別の xml ファイルになります

<transliteration>
<element>
    <source>about us</source>
        <target/>
</element>
</transliteration>

以下はスレッドの実行方法です

public void run() {

        MultipleDatabaseThread th = new MultipleDatabaseThread();
        Map<String,String> map = new HashMap<String,String>();

        try
        {
            Document doc = loadXmlContentToMemory(this.inputString);

            XPathExpression expr = null;
            XPathFactory xFactory = XPathFactory.newInstance();
            XPath xPath = xFactory.newXPath();
            expr = xPath.compile("/transliteration/element//source");
            Object result = expr.evaluate(doc, XPathConstants.NODESET);
            NodeList nodes = (NodeList) result;
            String sourceString = "";
            if(nodes.getLength() > 0)
            {
                for (int i=0; i<nodes.getLength();i++)
                {
                    //System.out.println("Name: "+nodes.item(i).getNodeName() +" Local Name: "+nodes.item(i).getLocalName() +" Value: "+nodes.item(i).getTextContent());
                    sourceString = nodes.item(i).getTextContent();
                    map = th.getCompleteStringTransliterate(sourceString, this.language);

                    if(map.get(sourceString) == null || map.get(sourceString).equals("") || map.get(sourceString).equals(sourceString))
                    {
                        map.clear();
                        map = th.getRecordsFromDatabase(sourceString, language);

                        Element abc = doc.createElement("target");

                        String targetString = "";

                        String[] tokens = sourceString.trim().split("\\s+");

                        for(int itr=0; itr < tokens.length; itr++)
                        {
                            targetString = targetString+" "+map.get(tokens[itr]);
                        }

                        abc.setTextContent(targetString.trim());
                        nodes.item(i).getParentNode().appendChild(abc);
                    }
                    else
                    {
                       Element abc = doc.createElement("target");
                       abc.setTextContent(map.get(sourceString));
                       nodes.item(i).getParentNode().appendChild(abc);
                    }
                }
            }

            try
            {

                expr = xPath.compile("/transliteration/element//target");
                result = expr.evaluate(doc, XPathConstants.NODESET);
            }catch(XPathExpressionException ex)
            {   }

            NodeList nodesList = (NodeList) result;

            for(int i =0;i<nodesList.getLength();i++)
            {
                System.out.println("Node Name: "+nodesList.item(i).getNodeName()+" Node Value: "+nodesList.item(i).getTextContent());
            }

            try
            {
                Transformer transformer = TransformerFactory.newInstance().newTransformer();
                StreamResult strResult = new StreamResult(new File(this.inputString+"_out.xml"));
                if(doc != null && strResult != null)
                {
                    DOMSource source = new  DOMSource(doc);
                    transformer.transform(source, strResult);
                }
            }
            catch(TransformerException ex)
            {
               System.out.println(""+ex);
            }
            catch(TransformerFactoryConfigurationError ex)
            {
               System.out.println(""+ex);
            }

        }catch(IOException ex)
        {
            ex.printStackTrace(System.out);
        }
        catch(DOMException ex)
        {
            ex.printStackTrace(System.out);
        } 
        catch(ParserConfigurationException ex)
        {
            ex.printStackTrace(System.out);
        }
        catch(SAXException ex)
        {
            ex.printStackTrace(System.out);
        }
        catch(XPathExpressionException ex)
        {
            ex.printStackTrace(System.out);
        }
        catch(InterruptedException ex)
        {
            ex.printStackTrace(System.out);
        }

    }

loadXmlContentToMemory** 関数は、ファイル名を入力として受け取り、XML コンテンツをドキュメントにロードします。
getCompleteStringTransliterate** は、ソースとそのターゲット文字列を含むマップ変数を返す MulltipleDatabaseThread クラスの関数です。

getRecordsFromDatabase** は、ソース文字列を分割し、そのターゲット文字列を再度取得する同じクラスの別の関数であり、マップ変数を返します

パブリッククラス MultipleDatabaseThread {

public Map<String,String> getCompleteStringTranslate(String inputString, String language) throws InterruptedException
{
    Map<String,String> map = new HashMap<String,String>();

    synchronized(OutputRecords.getMap())
    {
       //long startTime = System.currentTimeMillis();

       OutputRecords.clearOutputStream(); 
       Thread thCompleteString = new DatabaseThread(inputString, language);
       thCompleteString.start();
       thCompleteString.join();

       map = OutputRecords.getRecords();
       //System.out.println("Complete String Time Taken:: "+(System.currentTimeMillis()-startTime));
       return map;
    }
}



public Map<String,String> getRecordsFromDatabase(String inputString, String language) throws  InterruptedException
{
    String[] tokens = inputString.split("\\s+");

    Map<String,String> map = new HashMap<String,String>();

    Thread[] databaseThreads = new Thread[tokens.length];

    synchronized(OutputRecords.getMap())
    {
        //long startTime = System.currentTimeMillis();

        OutputRecords.clearOutputStream();
        for(int index=0; index < tokens.length; index++)
        {
            databaseThreads[index] = new DatabaseThread(tokens[index],language);
            databaseThreads[index].start();
        }
        for(int index = 0 ; index < tokens.length; index++)
        {
                databaseThreads[index].join();
        }

        map = OutputRecords.getRecords();
        //System.out.println("Tokens Time Taken:: "+(System.currentTimeMillis()-startTime));

        return map;

    }
}

}

これらの関数はどちらも、OutputRecord クラスで静的/共有マップ変数を使用し、複数のスレッドを生成して実際にデータベースを呼び出し、共有マップ変数を設定してその変数を返します。

しかし、このプログラムを実行すると、

Exception in thread "Thread-0" java.lang.NullPointerException
    at transliterationthreading.ExecuteOuterThread.run(ExecuteOuterThread.java:66)

オンライン

if(map.get(sourceString) == null || map.get(sourceString).equals("") || map.get(sourceString).equals(sourceString))

したがって、1 つのスレッドが終了してから、別のスレッドが完全に実行され、出力ファイルが生成されます。私はこの問題を解決するために誰かが何か提案を与えることができる問題を抱えていません。

ありがとう

score 0 · Accepted Answer

皆さんの努力に感謝します

静的共有マップを使用せず、ExecutorService および Callable Interface アプローチを使用して、別のアプローチを使用してこの問題を解決しようとしました

ここに私のコードがあります

try
        {
            doc = loadXmlContentToMemory(this.inputString);
            expr = xPath.compile("/transliteration/element//source");
            result = expr.evaluate(doc, XPathConstants.NODESET);

        }catch(ParserConfigurationException ex)
        {
            System.out.println("loadXmlError: "+ex.toString());
        }
        catch(IOException ex)
        {
            System.out.println("loadXmlError: "+ex.toString());
        }
        catch(SAXException ex)
        {
            System.out.println("loadXmlError: "+ex.toString());
        }
        catch(XPathExpressionException ex)
        {
            System.out.println("loadXmlError: "+ex.toString());
        }

        NodeList nodes = (NodeList) result;
        String sourceString = "";

        if(nodes.getLength() >0)
        {
            Map<String,String> fileMap = new HashMap<String,String>(); 
            ExecutorService executor = Executors.newFixedThreadPool(NTHREADS);

            for(int index =0; index <nodes.getLength(); index++)
            {
                sourceString = nodes.item(index).getTextContent();
                Callable<Map<String,String>> worker = new MultipleDatabaseCallable(sourceString,language);
                Future<Map<String,String>> map = executor.submit(worker);

                try
                {
                    //System.out.println(""+Thread.currentThread().getName()+"SourceString:: "+sourceString+"Map: "+map.get().get(sourceString));
                      fileMap.putAll(map.get());
                }catch(InterruptedException ex)
                {
                    System.out.println("future read: "+ex.toString());
                }
                catch(ExecutionException ex)
                {
                    System.out.println("future read: "+ex.toString());
                }
            }

            executor.shutdown();
            // Wait until all threads are finish
            while (!executor.isTerminated()) {

            }
            ExecutorService tokenExecutor = Executors.newFixedThreadPool(NTHREADS);
            for(int i =0 ;i<nodes.getLength();i++)
            {
                sourceString = nodes.item(i).getTextContent();
                if(fileMap.get(sourceString) == null || fileMap.get(sourceString).equals("") || fileMap.get(sourceString).equals(sourceString))
                {
                    fileMap.remove(sourceString);
                    Callable<Map<String,String>> worker = new MultipleTokenCallable(sourceString,language);
                    Future<Map<String,String>> map = tokenExecutor.submit(worker);

                    try
                    {
                        fileMap.putAll(map.get());
                    }
                    catch(InterruptedException ex)
                    {
                        System.out.println("Tokenized put Interupted exception: "+ex.toString());
                    }
                    catch(ExecutionException ex)
                    {
                        System.out.println("Tokenized put Execution exception: "+ex.toString());
                        ex.printStackTrace(System.out);
                    }

                    Element targetElement = doc.createElement("target");
                    String targetString = "";

                    String[] tokens = sourceString.trim().split("\\s+");

                    for(int itr=0; itr < tokens.length; itr++)
                    {
                        targetString = targetString+" "+fileMap.get(tokens[itr]);
                    }
                    targetElement.setTextContent(targetString.trim());
                    nodes.item(i).getParentNode().appendChild(targetElement);
                    //System.out.println(""+Thread.currentThread().getName()+" Target:  "+targetString+" Source:  "+sourceString);
                }
                else
                {
                    Element abc = doc.createElement("target");
                    abc.setTextContent(fileMap.get(sourceString));
                    nodes.item(i).getParentNode().appendChild(abc);
                }
            }

            tokenExecutor.shutdown();
            // Wait until all threads are finish
            while (!tokenExecutor.isTerminated()) {

            }
            try
            {
                Transformer transformer = TransformerFactory.newInstance().newTransformer();
                StreamResult strResult = new StreamResult(new File(this.inputString+"_out.xml"));
                if(doc != null && strResult != null)
                {
                    DOMSource source = new  DOMSource(doc);
                    transformer.transform(source, strResult);
                }
            }
            catch(TransformerException ex)
            {
               System.out.println(""+ex);
            }
            catch(TransformerFactoryConfigurationError ex)
            {
               System.out.println(""+ex);
            }

        }

これを使用して複数のスレッドが生成され、すべてのスレッドが同時にデータベースに接続しようとするため、同時スレッドの数が増えると、接続エラーが多すぎる可能性があります。したがって、その問題を克服するには接続プールを維持する必要があります

score 0 · Accepted Answer

ラインの評価中にマップの内容が変更されるのではないかと思います

if(map.get(sourceString) == null || map.get(sourceString).equals("") || map.get(sourceString).equals(sourceString))

このように null チェックは成功しますが、マップから取得した新しい値は null になる可能性があります。マップが同期されていません!

この行を次のように変更します

String sourceStringValue = map.get(sourceString);
if(sourceStringValue == null || sourceStringValue.equals("") || map.get(sourceString).equals(sourceString))

java - マルチスレッド データベース アプリケーションの実行中に java.lang.NullPointerException が発生する

2 に答える 2

Related

Reference

java - マルチスレッドデータベースアプリケーションの実行中に java.lang.NullPointerException が発生する