多线程并行的问题
我对java的多线程不是很熟悉,找了很久也没找到合适的例子.
我想实现这么个功能,在List里装有待处理的对象,用多个线程从List里取得对象并处理,把读取过的对象从List里删去..在操作list的时候加锁...
我自己试着写了个可是不象并行运行的,有谁能给我个例子么?不胜感激...
------解决方案--------------------老兄 加了锁你再怎么并行好象也没有用吧?
------解决方案-------------------- }else{
String ThreadName=Thread.currentThread().getName();
isReading=true;
long timeStart = System.currentTimeMillis();//test
long time=0;
if(sourceList.size()!=0){
atom=sourceList.get(0);
sourceList.remove(0);
isReading=false;
}
notify();
while(time>-1){
long timeEnd = System.currentTimeMillis();//test
time=(timeStart-timeEnd)/1000;
------解决方案--------------------代码贴错了吧?怎么run()方法后面完全不懂了。。。
------解决方案--------------------读取为什么要枷锁呀,读取时并没有引起内容的变化呀
在写入时才引起内容的变化,我感觉在写入是要枷锁啊
是不是读写线程的问题呀
------解决方案--------------------public synchronized void read()这说明同时只能有一个线程在执行这个函数
------解决方案--------------------public synchronized void read()这说明同时只能有一个线程在执行这个函数
你还在函数利用了wait?????
------解决方案--------------------你干脆用vector不就得了,直接不用考虑多线程得问题
------解决方案--------------------确实不懂你的意图....好像用不着wait(),notify()吧
再说构造每个Threadtestold对象的参数List是不是同一个啊
------解决方案--------------------List 有一个 remove 方法! 你对这个方法加锁就可以了!
像这样
Java code
public synchronized Object getItem(java.util.List list) {
Object obj = null;
if (list.size() <= 0)
return obj;
else
return list.remove(0);
}
------解决方案--------------------
Java code
public class Factory {
private static Factory factory;
private static Object classLock = Factory.class;
private Factory() {}
public static Factory getFactory() {
synchronized (classLock) {
if ( factory == null )
factory = new Factory();
return factory;
}
}
}