线程代码02
import java.util.ArrayList;import java.util.HashSet;
import java.util.Iterator;
import java.util.LinkedList;
import java.util.Queue;
import java.util.Set;
public class MemberMain implements Runnable {
// 作为缓冲区存放对象
private Set setMember = new HashSet();
// private Boolean isWriter = true;
// private Integer []i = new Integer;//{1,2,3,4,5,6,7,8,9};
// i = {1,2,3,4,5,6,7,8,9};
private int[] arr = { 1, 2, 3, 4, 5, 6, 7, 8, 9 };
private static ArrayList list = new ArrayList();
/**
* @param args
*/
public static void main(String[] args) {
// TODO Auto-generated method stub
// m.operateXml();
MemberMain m = new MemberMain();
// Product p = new Product();
// Custom c = new Custom();
// // 运行写线程；0－9写到一个容器中，最多放5个；
// new Thread(p).start();
// // 运行读线程；a/b依次取出数据；
// new Thread(c).start();
// 同一个对象的不同线程；
new Thread(m, "writeThread").start();
new Thread(m, "readThread").start();
}
public int[] getArr() {
return arr;
}
public synchronized void run() {
String thName = Thread.currentThread().getName();
System.out.println("thName =" + thName);
if (thName.equals("writeThread")) {
for (int i = 0; i < arr.length; i++) {
list.add(arr);
if (list.size() > 4) {
// try {
// Thread.sleep(1000);
// } catch (InterruptedException e) {
// e.printStackTrace();
// }
try {
wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
if (list.size() > 0) {
System.out.println("list1 =" + list);
notify();
}
} else {
if (null != list && list.size() > 0) {
Iterator iter = list.iterator();
while (iter.hasNext()) {
int i = (Integer) iter.next();
System.out.println("i =" + i);
iter.remove();
}
System.out.println("list2 =" + list);
if (list.size() == 0) {
notify();
try {
wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
}
}
页:
[1]