将RESULT传给10个Thread运行有关问题
日期：2014-05-20 浏览次数：20753 次
将RESULT传给10个Thread运行问题
依照以下方法使用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()) {
...............还有其他代码
...............
}
------解决方案--------------------
举例如下：
依照以下方法使用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 代表什么？
免责声明： 本文仅代表作者个人观点，与爱易网无关。其原创性以及文中陈述文字和内容未经本站证实，对本文以及其中全部或者部分内容、文字的真实性、完整性、及时性本站不作任何保证或承诺，请读者仅作参考，并请自行核实相关内容。
