关于java线程的锁的问题。

0 0

关于java线程的锁的问题。 0

private static Object lock = new Object();
...
public void run(){
	while(true){
		synchronized(lock){
			List<myObject> datas = dao.getDatas();
			for(myObject data : datas){
				myThread thread = new myThread();		    		
				thread.start();		    	
			}
		}
	}
}
public class myThread extends Thread{
	public void run(){   
		synchronized(xxx){
			//do something									
		}
	}							
}

在XXX处，应该怎么写，才能让线程针对每个myObject对象获取锁。
比如说List<myObject> datas = dao.getDatas()从数据库中获取到2个对象，
data1,data2,可以有两个线程运行 do something 代码块。
当有新的线程时，判断要针对哪个对象，并判断是否有针对该对象的线程正在运行。
如果有则等待，否则继续等待。

问题补充：场景是：每个myObject对象是一个数据库服务器，我的程序是定时从这些数据库服务器拉取相关数据，所以，myObject对象不会太多，并且每次从dao.getDatas()返回的对象值是不会变的，但是对象的标识（就是对象的内存地址）是会变的，因为每次dao.getDatas都是重新构造对象。

企业应用

2014年5月12日 11:49

zengjd
1
0 0 11

4个答案按时间排序按投票排序

0 0

你的这个

引用

dao.getDatas();

是有其它线程在改变吗？
场景没太看明白，是想一边修改Data，另一边遍历吗？
这种场景可以使用CopyOnWriteArrayList，该容器不需要加锁，可以方便的遍历，同时没有ConcurrentModification异常。

2014年5月12日 13:50

chainhou
192
0 0 15

1条评论

0 0

如果你能保证dao.getDatas()返回的对象是不会变的，则可以直接对myObject对象进行加锁。

如果不能保证，则需要一个映射机制，让每个myObject对象能对应一把锁，然后对那把锁进行同步。

不过最好是把你的场景描述更清楚一些，这样才能更好的分析问题，并且从你现在的方案来说，每个myObject起一个线程的使用场景可能会有问题，那就是当myObject会有很多对象的时候，就会起大量的线程，这个可能会造成应用的性能问题。一个应用最好不要起太多的线程，如果一件事情需要多线程做的话，可以尝试使用线程池，以及任务调度的方式来工作，而不是每一份工作都需要起一个新线程。

2014年5月12日 12:46

lbfhappy
281
0 0 15

3条评论

0 0

Thread永远是新的对象，所以永远无法达到锁方法的要求解决办法如下

在外面写一个加锁的外部方法如 public synchronized void test（）{} 然后在run方法中调用 test（）

2014年5月12日 12:14

千年松鼠
82
0 0 13

添加评论

0 0

1.List<myObject> datas = dao.getDatas();
如果这句能保证每次获取到不同的数据，则这里不用在线程中再加锁。

2.如果非要加锁，则：
public class myThread extends Thread{
myobject obj;

public void setObj(myobject obj){
this.obj = obj;
}
}

调用前，将obj设置进去，这样可以满足你目前的需要，但首先再验证下1.

2014年5月12日 12:03