创建一个多线程应用程序,该程序创建多个线程并查询同一个数据库表
给定格式为xml的输入文件:
<transliteration>
<element>
<source>about us</source>
</element>
</transliteration>
该应用程序读取多个文件,为每个xml文件创建一个线程,输出将是另一个具有格式的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** function takes filename as a input and loads xml content in the Document.
getCompleteStringTransliterate** is a function of MulltipleDatabaseThread class which returns a map variable which contain source and its traget string in it.
getRecordsFromDatabase** is anoher function in same class which splits source string and gets its target string again returns map variable
public class 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; } }
}
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))
所以一个线程被终止,然后其他线程完全执行并生成输出文件。我不明白问题在哪里,请问有人能提供解决此问题的建议吗?
谢谢
map
为空。map = OutputRecords.getRecords();
导致它为空吗? - sanbhat