线程池

线程池概念

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

 

线程池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--);

               }

            }

        }

    }

}

 

}

原文地址:https://www.cnblogs.com/1997WY/p/10707405.html