zoukankan      html  css  js  c++  java
  • 线程池

    线程池概念

    线程池,其实就是一个容纳多个线程的容器,其中的线程可以反复使用,省去了频繁创建线程对象的操作,无需反复创建线程而消耗过多资源。

     

    线程池Runnable接口

    l  Executors:线程池创建工厂类

    n  public static ExecutorService newFixedThreadPool(int nThreads):返回线程池对象

    l  ExecutorService:线程池类

    n  Future<?>submit(Runnable task):获取线程池中的某一个线程对象,并执行

    l  Future接口:用来记录线程任务执行完毕后产生的结果。线程池创建与使用

     

    l  使用线程池中线程对象的步骤:

    n  创建线程池对象

    n  创建Runnable接口子类对象

    n  提交Runnable接口子类对象

    n  关闭线程池

     

    Runnable代码解释

    public class ThreadPoolDemo {

        public static void main(String[] args) {

            //创建线程池对象

            ExecutorService service = Executors.newFixedThreadPool(2);//包含2个线程对象

            //创建Runnable实例对象

            MyRunnable r = new MyRunnable();

           

            //自己创建线程对象的方式

            //Thread t = new Thread(r);

            //t.start(); ---> 调用MyRunnable中的run()

           

            //从线程池中获取线程对象,然后调用MyRunnable中的run()

            service.submit(r);

            //再获取个线程对象,调用MyRunnable中的run()

            service.submit(r);

            service.submit(r);

    //注意:submit方法调用结束后,程序并不终止,是因为线程池控制了线程的关闭。将使用完的线程又归还到了线程池中

     

    //关闭线程池

            //service.shutdown();

        }

    }

    l  Runnable接口实现类

    public class MyRunnable implements Runnable {

        @Override

        public void run() {

            System.out.println("我要一个教练");

           

            try {

               Thread.sleep(2000);

            } catch (InterruptedException e) {

               e.printStackTrace();

            }

            System.out.println("教练来了: " +Thread.currentThread().getName());

            System.out.println("教我游泳,交完后,教练回到了游泳池");

        }

    }

     

    使用线程池方式—Callable接口

    l  Callable接口:与Runnable接口功能相似,用来指定线程的任务。其中的call()方法,用来返回线程任务执行完毕后的结果,call方法可抛出异常。

    l  ExecutorService:线程池类

    n  <T> Future<T>submit(Callable<T> task):获取线程池中的某一个线程对象,并执行线程中的call()方法

    l  Future接口:用来记录线程任务执行完毕后产生的结果。线程池创建与使用

     

    l  使用线程池中线程对象的步骤:

    n  创建线程池对象

    n  创建Callable接口子类对象

    n  提交Callable接口子类对象

    n  关闭线程池

     

    public class ThreadPoolDemo {

        public static void main(String[] args) {

            //创建线程池对象

            ExecutorService service = Executors.newFixedThreadPool(2);//包含2个线程对象

            //创建Callable对象

            MyCallable c = new MyCallable();

           

            //从线程池中获取线程对象,然后调用MyRunnable中的run()

            service.submit(c);

           

            //再获取个教练

            service.submit(c);

            service.submit(c);

    //注意:submit方法调用结束后,程序并不终止,是因为线程池控制了线程的关闭。将使用完的线程又归还到了线程池中

     

    //关闭线程池

            //service.shutdown();

        }

    }

    l  Callable接口实现类,call方法可抛出异常、返回线程任务执行完毕后的结果

    public class MyCallable implements Callable {

        @Override

        public Object call() throws Exception {

            System.out.println("我要一个教练:call");

            Thread.sleep(2000);

            System.out.println("教练来了: " +Thread.currentThread().getName());

            System.out.println("教我游泳,交完后,教练回到了游泳池");

            return null;

        }

     

    线程同步代码块

    (火车票)

    同步代码块: 在代码块声明上 加上synchronized

    synchronized (锁对象) {

        可能会产生线程安全问题的代码

    }

    同步代码块中的锁对象可以是任意的对象;但多个线程时,要使用同一个锁对象才能够保证线程安全。

     

    使用同步代码块,对电影院卖票案例中Ticket类进行如下代码修改:

    publicclass Ticket implements Runnable {

        //共100票

        intticket = 100;

        //定义锁对象

        Object lock = new Object();

        @Override

        publicvoid run() {

            //模拟卖票

            while(true){

               //同步代码块

                synchronized (lock){

                   if (ticket> 0) {

                       //模拟电影选坐的操作

                       try {

                           Thread.sleep(10);

                       } catch (InterruptedException e) {

                           e.printStackTrace();

                       }

                       System.out.println(Thread.currentThread().getName() + "正在卖票:" + ticket--);

                   }

                }

            }

        }

    }

     

    }

  • 相关阅读:
    细说MS事务管理
    大话设计模式(含源码)下载
    CSS基础到提高(PPT、视频、源代码),网页布局不用愁
    Android开发中Layout中明明改了id,但是还出现"cannot be resolved or is not a field"的原因
    读《OO真经》有感,以及我自己的关于哲学的体会
    Web服务小试牛刀
    在Android的RaletiveLayout中,如果空间的相对位置矛盾将不显示此控件
    .net 面试题2
    敏捷软件转
    中英文标点
  • 原文地址:https://www.cnblogs.com/1997WY/p/10707405.html
Copyright © 2011-2022 走看看