首页 > 代码库 > 并发的集合类
并发的集合类
package duoxiancheng; import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.BlockingQueue; public class TestQueue { public static void main(String[] args) { BlockingQueue<String> queue=new ArrayBlockingQueue<String>(10); new Save(queue).start(); new Get(queue).start(); new Get(queue).start(); } } class Save extends Thread{ BlockingQueue<String> queue; static Object obj="hello"; static int i=0; public Save(BlockingQueue<String> queue) { super(); this.queue = queue; } public void run(){ while(true){ try { synchronized (obj) { queue.put("张飞"+i++); } Thread.sleep(2000); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } } class Get extends Thread{ BlockingQueue<String> queue; public Get(BlockingQueue<String> queue) { super(); this.queue = queue; } public void run(){ int i=1; while(true){ try { System.out.println("队列中的个数是"+queue.size()); System.out.println(Thread.currentThread().getName()+":"+queue.take()); Thread.sleep(1000); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } }
并发的集合类
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。