2
У меня есть приложение Java, в котором я запускаю 100 потоков. Потоки, после разбора XML-файлов и извлечения из них какого-либо текста, откройте файл для записи извлеченного текста. Однако кажется, что они смешивают результаты (выходной файл не находится в предполагаемом порядке). Я использовал Lock, но это не решило проблему. Может ли кто-нибудь помочь?Java многопоточность смешивает текст в нерабочем режиме file-lock
Main.java
public class Main {
public static void main(String[] args) throws FileNotFoundException, IOException, InterruptedException {
FileInputStream fstream = new FileInputStream("C:\\Users\\Michael\\outfilenames0.txt");
BufferedReader br = new BufferedReader(new InputStreamReader(fstream));
String strLine;
int j=0;
while (((strLine = br.readLine()) != null) && (j<100))
{
int activethreads=Thread.activeCount();
SimpleThread t=new SimpleThread(strLine);
t.start();
if (activethreads>100)
SimpleThread.sleep(250);
if (j==99)
{j=-1;}
//System.out.println(t.getName());
j++;
}
}
}
class SimpleThread extends Thread {
private String str;
public SimpleThread(String str) {
this.str=str;
}
@Override
public void run() {
try {
Lock l=new ReentrantLock();
if (l.tryLock()){
try {
SAXParserFactory factory = SAXParserFactory.newInstance();
// create SAX-parser...
SAXParser parser=factory.newSAXParser();
SaxHandler handler = new SaxHandler();
parser.parse(str, handler);
} catch (ParserConfigurationException ex) {
Logger.getLogger(SimpleThread.class.getName()).log(Level.SEVERE, null, ex);
}finally {l.unlock();}
} else Thread.currentThread().sleep(10);
} catch (InterruptedException ex) {
Logger.getLogger(SimpleThread.class.getName()).log(Level.SEVERE, null, ex);
} catch (SAXException ex) {
Logger.getLogger(SimpleThread.class.getName()).log(Level.SEVERE, null, ex);
} catch (IOException ex) {
Logger.getLogger(SimpleThread.class.getName()).log(Level.SEVERE, null, ex);
}
}
}
class SaxHandler extends DefaultHandler {
private boolean invention_title = false;
private boolean invention_title_lang = false;
private boolean abstr = false;
private boolean abstr_lang = false;
private boolean descr = false;
private boolean description_lang = false;
private String doc="";
private String ucid;
@Override
public void startElement(String uri, String localName,
String qName, Attributes attrs) throws SAXException {
if (qName.equals("patent-document")) {
ucid = attrs.getValue("ucid");
doc= ("<DOC>\n<DOCNO> " + ucid +"</DOCNO> \n<TEXT>");
}
if (qName.equalsIgnoreCase("invention-title")) {
invention_title = true;
String title_language = attrs.getValue("lang");
if (title_language.equals("EN"))
{
invention_title_lang = true;
doc=doc+"<TITLE>"+"\n";
}
}
if (qName.equalsIgnoreCase("abstract")) {
abstr = true;
String abst_language = attrs.getValue("lang");
if (abst_language.equals("EN")) {abstr_lang = true;
doc=doc+"<ABSTRACT>"+"\n" ;
}
}
if (qName.equalsIgnoreCase("description")) {
descr = true;
String des_language = attrs.getValue("lang");
if (des_language.equals("EN")) {description_lang = true;
doc=doc+"<DESCRIPTION>"+"\n";
}
}}
@Override
public void endElement (String uri, String localName, String qName)
throws SAXException
{
if((qName.equals("abstract"))&& (abstr_lang)){
abstr_lang = false;
doc=doc+"</ABSTRACT>"+"\n";
}
if((qName.equals("invention-title"))&&(invention_title_lang)){
invention_title_lang = false;
doc=doc+"</TITLE>"+"\n";
}
if((qName.equals("description"))&&(description_lang)){
description_lang = false;
doc=doc+"</DESCRIPTION>"+"\n";
}
if(qName.equals("patent-document")){
doc=doc+"</TEXT>"+"\n"+"</DOC>"+"\n";
//System.out.println("</DOC>");
//Lock l=new ReentrantLock();
// if (l.tryLock())
//try {
FileWrite fileWrite = new FileWrite();
try {
fileWrite.FileWrite(ucid, doc);
} catch (IOException ex) {
Logger.getLogger(SaxHandler.class.getName()).log(Level.SEVERE, null, ex);
}
// }finally {l.unlock();}
// catch (IOException ex) {
//Logger.getLogger(SaxHandler.class.getName()).log(Level.SEVERE, null, ex);
// }
}
}
@Override
public void characters(char ch[], int start, int length)
throws SAXException {
if (invention_title_lang) {
doc=doc+ (new String(ch, start, length))+"\n";
}
if (abstr_lang) {
doc=doc+ (new String(ch, start, length));
}
if (description_lang) {
doc=doc+ (new String(ch, start, length));
}
}
}
class FileWrite
{
public synchronized void FileWrite(String ucid, String doc) throws IOException
{
Thread t=Thread.currentThread();
try{
FileWriter fstreamout = new FileWriter("EP-022",true);
BufferedWriter out = new BufferedWriter(fstreamout);
out.write(doc);
out.close();
if (t.isAlive())
{
t.stop();}
}
catch (Exception e)
{
System.err.println("Error"+e.getMessage());
}
}
}
Какой заказ вы ожидаете? – pingw33n