依照以下方法使用10个Thread运行时会发生前一个获取result.next()还未处理完就被另一个Thread运行result.next()所以获取的数据不正确,请教由外部传入的result可以怎么设置?
public class SimpleThread extends Thread {
public static String filter=";";
public static int i=0;
public ResultSet result;
public static HashMap<String,Vector<HashMap>> hm;
public SimpleThread(ResultSet result,HashMap<String,Vector<HashMap>> hm) {
this.result=result;
this.hm=hm;
}
public void run() {
System.out.println("simple start");
Date ttstart = new Date();
SimpleDateFormat ttf = new SimpleDateFormat("yyyy/MM/dd hh:mm:ss");
System.out.println(ttf.format(ttstart));
long arrt1 = System.currentTimeMillis();
try {
while (result.next()) {
...............还有其他代码
...............
}
------解决方案--------------------
举例如下:
- Java code
try { synchronized(result){ // 获取该行的所有值之前给result对象加锁 if (result.next()) { int id = result.getInt(1); // ...... String s = result.getString(10); } } // 获取该行的所有值后同步锁解除 //其它代码 } catch (Exception e){}
------解决方案--------------------
举例如下:
- Java code
try { synchronized(result){ // 获取该行的所有值之前给result对象加锁 if (result.next()) { int id = result.getInt(1); // ...... String s = result.getString(10); } } // 获取该行的所有值后同步锁解除 //其它代码 } catch (Exception e){}
------解决方案--------------------
没有必要的,因为获取result对象锁的对象只能有一个,一个对象不可能同时获取A,B两个对象的锁的
------解决方案--------------------
如1楼所说,在result的存取上加锁即可避免发生问题。
但我个人更建议的方式是,不要将ResultSet传进来,而是包装成另外一个对象,在其所提供的方法上进行加锁,而该方法则直接返回一个独立于ResultSet的POJO对象。这样各模块的职责边界更为清晰,降低出现误访问ResultSet而导致数据不一致的风险。
另外,楼主你在3楼写的代码,没看懂目的为何?A B 代表什么?