有关线程池，生产消费模型，和多线程的线程安全

前言我们在前面做过小球动态屏保的开发那是一个以线程为背景的小项目到目前为止项目做的还不错现在我们以此为背景说一说后续开发过程中可能会遇到的问题。关于多进程常见的问题首先我们先来说一说生活中的类似问题当你和朋友一起去取钱而银行只有一个窗口这个时候想象一下会发生什么问题是的一个窗口没法同时为两个不同的人进行服务这个时候我们就需要用到线程锁的概念了也很好理解一个人在执行取钱操作的时候先用一把锁把这个窗口锁上另一个在外面等待等到结束之后我们再将这个窗口开启如此循环这样就可以了。packageThreadLocks;publicclassMain{publicstaticvoidmain(String[]args){MoneymoneynewMoney();Useru1newUser(money);u1.setName(User1);u1.start();Useru2newUser(money);u2.setName(User2);u2.start();}}好嘞下面要干的是另一件事你可以看到我在这个代码中并未使用任何与锁有关的东西说明锁不在二人手中是可以理解的若是二人用各自的锁那没办法让另一个人解开可是上街的时候忘了带锁钱就取不成了吗所以锁由银行统一提供importjava.util.HashMap;importjava.util.concurrent.locks.Lock;importjava.util.concurrent.locks.ReentrantLock;publicclassMoney{HashMapString,IntegeraccountnewHashMap();publicLocklnewReentrantLock();intmoney10;}好的下面开始执行取钱操作packageThreadLocks;importjava.util.concurrent.locks.Lock;importjava.util.concurrent.locks.ReentrantLock;publicclassUserextendsThread{publicMoneymoney;publicUser(Moneymoney){this.moneymoney;}publicvoidrun(){for(inti0;i50;i){try{Thread.sleep(10);}catch(InterruptedExceptione){thrownewRuntimeException(e);}money.l.lock();try{System.out.println((Thread.currentThread().getName()已存money.money1元));money.money1;}finally{money.l.unlock();}}}}这样就可以了成功地实现了应有的操作。上面展示了一种写法其实银行那里不用那么定义可以是使用一个synchronized关键字它和lock的作用是一样的这里笔者为了好说明使用了前面的写法。synchronized(money){System.out.println((Thread.currentThread().getName()已取money.money1元));money.money1;}好的以上是关于线程锁的问题。生产消费模型这也是个很经典的模型。比如说现在有一个厨师两位客人厨师需要源源不断的做出食物放到架子上客人则是架子上一有食物就开始消费直到架子为空。而厨师当架子上满了则停止架子上空了就继续。那么我们看见有三个对象厨师架子顾客。还是一样的好理解但是还是要加上锁因为这个时候那个架子变成了那个窗口了不能支持两种同时访问。以下可以看作顾客的内容packageaThread;importjava.util.List;publicclassCustomerimplementsRunnable{publicListIntegerlist;publicCustomer(ListIntegerlist){this.listlist;}inti1;publicintMax20;publicvoidrun(){while(true){try{Thread.sleep(600);}catch(InterruptedExceptione){thrownewRuntimeException(e);}synchronized(list){while(list.size()0){try{System.out.println(消费者睡眠);list.wait();}catch(InterruptedExceptione){thrownewRuntimeException(e);}}list.remove(0);System.out.println(厂库剩下list.size());list.notifyAll();}}}}可以想见我们的生产方也是一样的操作。packageaThread;importjava.util.List;publicclassProduceimplementsRunnable{publicListIntegerlist;publicProduce(ListIntegerlist){this.listlist;}inti1;publicintMax20;publicvoidrun(){while(true){try{Thread.sleep(200);}catch(InterruptedExceptione){thrownewRuntimeException(e);}synchronized(list){while(list.size()Max){try{System.out.println(生产者睡眠);list.wait();}catch(InterruptedExceptione){thrownewRuntimeException(e);}}list.add(i);System.out.println(Thread.currentThread().getName()厂库当前数据list.size());list.notifyAll();}}}}而我们的架子则是作为主入口packageaThread;importjava.util.ArrayList;importjava.util.LinkedList;importjava.util.List;publicclassMain{publicstaticvoidmain(String[]args){ListIntegerlistnewArrayList();//Java的自动转型子转父类ProducepnewProduce(list);CustomercnewCustomer(list);newThread(p,p2).start();newThread(p,p1).start();newThread(c).start();}}好了。大致模型就是如此。线程池最后我们来说说线程池的内容。线程池在Java中有自己的关键字ThreadPool。一般有5个参数核心线程最大线程等待时间任务队列还有新线程的工厂。一般来讲当我们的线程数小于等于核心线程数时我们都会正常执行核心线程等待时间过后我们的最大线程中的下一部分就会开始申请资源。以此我们的线程池中的线程就会不断减少直至为0即我们同时处理核心线程数的线程同时存储核心线程数等待任务队列中的数字那么多的线程。就这些。