精华内容
下载资源
问答
  • * 四个线程ABCD,分别打印A/B/C/D */ public class ABCD { public static void main(String[] args) { new PrintABCD().start(); } } class PrintABCD { private static enum PrintStatus { A, B, C, D }...
    /**
     * 四个线程ABCD,分别打印A/B/C/D
     */
    public class ABCD {
    	public static void main(String[] args) {
    		new PrintABCD().start();
    	}
    }
    
    class PrintABCD {
    	private static enum PrintStatus {
    		A, B, C, D
    	};
    
    	private static PrintStatus nstatus;
    
    	public void start() {
    		nstatus = PrintStatus.A;
    
    		Thread thread1 = new Thread(new PrintA());
    		Thread thread2 = new Thread(new PrintB());
    		Thread thread3 = new Thread(new PrintC());
    		Thread thread4 = new Thread(new PrintD());
    
    		thread1.start();
    		thread2.start();
    		thread3.start();
    		thread4.start();
    	}
    
    	private synchronized void print(PrintStatus status) {
    		if (nstatus == status) {
    			// System.out.println(Thread.currentThread().getName() + " ");
    			System.out.print(status);
    			if (status == PrintStatus.D) {
    				System.out.println();
    			}
    			changeStatus();
    			return;
    		}
    
    	}
    
    	private void changeStatus() {
    		if (nstatus == PrintStatus.D) {
    			nstatus = PrintStatus.A;
    			return;
    		}
    		if (nstatus == PrintStatus.A) {
    			nstatus = PrintStatus.B;
    			return;
    		}
    		if (nstatus == PrintStatus.B) {
    			nstatus = PrintStatus.C;
    			return;
    		}
    		if (nstatus == PrintStatus.C) {
    			nstatus = PrintStatus.D;
    			return;
    		}
    	}
    
    	private class PrintA implements Runnable {
    		@Override
    		public void run() {
    			// TODO Auto-generated method stub
    			Thread.currentThread().setName("printa: ");
    			while (true) {
    				print(PrintStatus.A);
    			}
    		}
    	}
    
    	private class PrintB implements Runnable {
    		@Override
    		public void run() {
    			// TODO Auto-generated method stub
    			Thread.currentThread().setName("printb: ");
    			while (true) {
    				print(PrintStatus.B);
    			}
    		}
    	}
    
    	private class PrintC implements Runnable {
    		@Override
    		public void run() {
    			// TODO Auto-generated method stub
    			Thread.currentThread().setName("printc: ");
    			while (true) {
    				print(PrintStatus.C);
    			}
    		}
    	}
    
    	private class PrintD implements Runnable {
    		@Override
    		public void run() {
    			// TODO Auto-generated method stub
    			Thread.currentThread().setName("printd: ");
    			while (true) {
    				print(PrintStatus.D);
    			}
    		}
    	}
    }

    
    
    展开全文
  • 有四个线程1、2、3、4。 线程1的功能就是输出1, 线程2的功能就是输出2,以此类推………现在四个文件ABCD。 初始都为空。 现要让四个文件呈如下格式: A:1 2 3 4 1 2…. B:2 3 4 1 2 3…. C:3 4 1 2 3 4...

    有四个线程1、2、3、4。
    线程1的功能就是输出1,
    线程2的功能就是输出2,以此类推………现在有四个文件ABCD。
    初始都为空。
    现要让四个文件呈如下格式:
    A:1 2 3 4 1 2….
    B:2 3 4 1 2 3….
    C:3 4 1 2 3 4….
    D:4 1 2 3 4 1….
    请设计程序。

    先试着写出四个线程交替写入A文件

    public class FourThreadOneFile  
    {
        public static FILE file = new FILE();
    
        public static void main(String[] args) 
        {
            System.out.println("Hello World!");
            ExecutorService executors = Executors.newFixedThreadPool(5);
            executors.execute(new PrintTask(1));
            executors.execute(new PrintTask(2));
            executors.execute(new PrintTask(3));
            executors.execute(new PrintTask(4));
            executors.shutdown();
        }
        static class PrintTask implements Runnable
        {
            private int id = 0;
            public PrintTask(int id){
                this.id = id;
            }
            public void run(){
                while(true){
                    file.print(id);
                }
            }
        }
    }
    
    class FILE
    {
        //private static Lock = new ReentrantLock();
        private static int state = 0;
        private static PrintWriter out;
    
        public FILE(){
            try{
                out = new PrintWriter("A.txt");
            }catch(Exception fileNotFound){
    
            }
        }
    
        public static synchronized void  print(int id) {
            if(state == (id - 1)){
                try{
                    out.print(id);
                    System.out.println(id);
                    Thread.sleep(1000);
                }catch(InterruptedException ex1){
    
                }finally{
                    //刷新缓冲区
                    out.flush();
                }
                state++;
                if(state == 4){
                    out.println();
                    state = 0;
                }
            }
        }
    }

    扩展到四个文件

    为任务类指定id和name
    id表示打印的顺序
    name表示打印时打印的字符

    id需要根据情况在文件类里时刻调整顺序

    public class FourThreadFourFile  
    {
        public static FILE file = new FILE();
    
        public static void main(String[] args) throws Exception
        {
            System.out.println("Hello World!");
            PrintWriter o = new PrintWriter("B");
            o.println("hello");
            o.close();
            ExecutorService executors = Executors.newFixedThreadPool(5);
            executors.execute(new PrintTask(1,"1"));
            executors.execute(new PrintTask(2,"2"));
            executors.execute(new PrintTask(3,"3"));
            executors.execute(new PrintTask(4,"4"));
            executors.shutdown();
        }
        public static class PrintTask implements Runnable
        {
            private int id = 0;
            public String name;
            public PrintTask(int id,String name){
                this.id = id;
                this.name = name;
            }
            public void run(){
                while(true){
                    file.printFile(id,this);
                }
            }
        }
    }
    
    class FILE
    {
        //private static Lock = new ReentrantLock();
        //代表需要打印的数
        private static int state = 0;
        //选择操作文件
        //0---A
        //1---B
        //2---C
        //3---D
        private static int select = 0; 
        private static PrintWriter outA;
        private static PrintWriter outB;
        private static PrintWriter outC;
        private static PrintWriter outD;
    
        private static PrintWriter out;
        public FILE(){
            try{
                outA = new PrintWriter("A.txt");
                outB = new PrintWriter("B.txt");
                outC = new PrintWriter("C.txt");
                outD = new PrintWriter("D.txt");
    
            }catch(Exception fileNotFound){
    
            }
        }
        public static synchronized void printFile(int id,FourThreadFourFile.PrintTask pt){
            switch(select){
                case 0:
                    out = outA;
                    print(id,pt);
                    break;
                case 1:
                    out = outB;
                    //调整id
                    id = id - 1;
                    if(id <= 0){
                        id += 4; 
                    }
                    print(id,pt);
                    break;
                case 2:
                    out = outC;
                    //调整id
                    id = id - 2;
                    if(id <= 0){
                        id += 4; 
                    }
                    print(id,pt);
                    break;
                case 3:
                    out = outD;
                    id = id - 3;
                    //调整id
                    if(id <= 0){
                        id += 4; 
                    }
                    print(id,pt);
                    break;
            }
    
        }
    
        public static synchronized void  print(int id,FourThreadFourFile.PrintTask pt) {
            if(state == (id - 1)){
                try{
                    out.print(pt.name);
                    System.out.println((char)('A'+select)+"-----" + pt.name);
                    Thread.sleep(1000);
                }catch(InterruptedException ex1){
    
                }finally{
                    //刷新缓冲区
                    out.flush();
                }
                state++;
                if(state == 4){
                    out.println();
                    state = 0;
                    select++;
                    if(select == 4){
                        select = 0;
                    }
                }
            }
        }
    }

    这里写图片描述

    展开全文
  • 有四个线程1、2、3、4, 线程1的功能就是输出1,线程2的功能就是输出2, 以此类推.........  现在四个文件A B C D, 初始都为空。现要让四个文件呈如下格式: A:1 2 3 4 1 2.... B:2 3 4 1 2 3.... C:3 ...

    具体题目如下:

    有四个线程1、2、3、4,

    线程1的功能就是输出1,线程2的功能就是输出2,
    以此类推......... 
    现在有四个文件A B C D,
    初始都为空。现要让四个文件呈如下格式:
    A:1 2 3 4 1 2....
    B:2 3 4 1 2 3....
    C:3 4 1 2 3 4....

    D:4 1 2 3 4 1....

    以上就是我看到的一个多线程相关的面试题,看完了 ,就想想怎么实现。

    下面就看代码

    理论上讲,都是从main方法走起,

    package com.lxk.threadTest.mianShiTest.googleTest;
    
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    
    /**
     * 有四个线程1、2、3、4。
     * <p>
     * 线程1的功能就是输出1,线程2的功能就是输出2,
     * <p>
     * 以此类推......... 现在有四个文件A B C D,
     * 初始都为空。现要让四个文件呈如下格式:
     * A:1 2 3 4 1 2....
     * B:2 3 4 1 2 3....
     * C:3 4 1 2 3 4....
     * D:4 1 2 3 4 1....
     * <p>
     * Created by lxk on 2017/7/14
     */
    public class Main {
        public static void main(String[] args) {
            FileWriteUtil util = new FileWriteUtil();
            ExecutorService service = Executors.newCachedThreadPool();
            service.execute(new WriteRunnable(util, 1, '1'));
            service.execute(new WriteRunnable(util, 2, '2'));
            service.execute(new WriteRunnable(util, 3, '3'));
            service.execute(new WriteRunnable(util, 4, '4'));
            service.shutdown();
    
            //new Thread(new WriteRunnable(util, 1, '1')).start();
            //new Thread(new WriteRunnable(util, 2, '2')).start();
            //new Thread(new WriteRunnable(util, 3, '3')).start();
            //new Thread(new WriteRunnable(util, 4, '4')).start();
        }
    }

    上面关于启动线程,有2中方式,

    第一种,也就是未注释的,略显高级点,看类名大概就知道使用的是个线程池的东西。这个实现姿势有很多种。这只是其中的一个。

    第二种,也就是下面注释的代码,也不low,是我们常见的启动线程 的方式。


    然后就是我们说的那个实现多线程的类的实现啦

    package com.lxk.threadTest.mianShiTest.googleTest;
    
    /**
     * Created by lxk on 2017/7/14
     */
    public class WriteRunnable implements Runnable {
        private final FileWriteUtil util;
        private int threadNum;
        private char value;
    
        /**
         * @param util      写文件工具类
         * @param threadNum 线程号
         * @param value     写的字符
         */
        public WriteRunnable(FileWriteUtil util, int threadNum, char value) {
            this.util = util;
            this.threadNum = threadNum;
            this.value = value;
        }
    
        public void run() {
            /*
             * 假设循环6次,一直循环可以使用while(true)或者for(;;)
             */
            for (int i = 0; i < 6; i++) {
                synchronized (util) {
                    while (threadNum != util.getCurrentThreadNum()) {
                        try {
                            util.wait();
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                    }
                    util.write(value, threadNum);
                    util.notifyAll();
                }
            }
        }
    }
    

    最后,就是这个写文件的类啦。

    package com.lxk.threadTest.mianShiTest.googleTest;
    
    import java.io.FileWriter;
    import java.io.IOException;
    
    /**
     * 此类,是四个线程共享的,
     * <p>
     * Created by lxk on 2017/7/14
     */
    public class FileWriteUtil {
        private int currentThreadNum = 1;
        /**
         * 记录将字符写入文件的次数
         */
        private int count = 0;
    
        private String currentFileName;
    
        public void write(char value, int threadNum) {
            getCurrentFileName();
            FileWriter writer = null;
            try {
                //生成文件位置
                writer = new FileWriter("D:/test/test/" + currentFileName + ".txt", true);
                writer.write(value + " ");
                System.out.printf(
                        "ThreadNum=%d is executing. %c is written into file file%s.txt \n",
                        currentThreadNum, value, currentFileName);
                writer.flush();
                //System.out.println(count);//
                count++;
                currentThreadNum = threadNum;
            } catch (IOException e) {
                e.printStackTrace();
            }
    
            if (null != writer) {
                try {
                    writer.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            getNextThreadNum();
        }
    
        public int getCurrentThreadNum() {
            return currentThreadNum;
        }
    
        public void setCurrentThreadNum(int currentThreadNum) {
            this.currentThreadNum = currentThreadNum;
        }
    
        /**
         * 根据写的次数,判断该写哪个文件了?A,B,C,D.
         */
        private void getCurrentFileName() {
            int temp = count % 4;
            switch (temp) {
                case 0:
                    currentFileName = "A";
                    break;
                case 1:
                    currentFileName = "B";
                    break;
                case 2:
                    currentFileName = "C";
                    break;
                case 3:
                    currentFileName = "D";
                    break;
                default:
                    currentFileName = "E";
            }
        }
    
        private void getNextThreadNum() {
            if (count % 4 == 0) {
                if (currentThreadNum < 3) {
                    currentThreadNum += 2;
                } else {
                    currentThreadNum = (currentThreadNum + 2) % 4;
                }
            } else {
                if (currentThreadNum == 4) {
                    currentThreadNum = 1;
                } else {
                    currentThreadNum++;
                }
            }
        }
    }
    

    最后,就是看下代码实际运行的结果。


    从打印结果看,看到了是四个线程在跑,而且分别写入到ABCD四个文件去。


    注意,图中的红线框,奥,也可以不注意啦。

    其实,说得最透彻点,就是这四个线程,轮着执行,

    每次,都是有一个线程可以执行,这的执行也就是写文件啦,然后其他的三个都稍息,也是wait()啦。

    等这个线程执行完毕之后,也就是写文件完毕之后,唤醒另外三个在wait()的线程,然后,设置一下,下一个可以处于运行态的线程,然后又开始重复了。

    不能执行的,都wait(),如此往复。

    这里有个需要注意的是。

    这四个线程都在共享操作的就是那个写文件工具类。也就是对这个上锁。四个线程用的是一个锁,那就可以保证线程安全啦。

    理论,是这个理论,但是,真让你写,可不一定能分分钟就写好。



    展开全文
  • 线程创建的种方式

    万次阅读 多人点赞 2018-03-30 14:34:14
    java中创建线程种方法以及区别 Java使用Thread类代表线程,所有的线程对象都必须是Thread类或其子类的实例。Java可以用种方式来创建线程,如下所示: ...下面让我们分别来看看这种创建线程的方法。 --...

    java中创建线程的四种方法以及区别

    Java使用Thread类代表线程,所有的线程对象都必须是Thread类或其子类的实例。Java可以用四种方式来创建线程,如下所示:

    1)继承Thread类创建线程

    2)实现Runnable接口创建线程

    3)使用Callable和Future创建线程

    4)使用线程池例如用Executor框架

    下面让我们分别来看看这四种创建线程的方法。

    ------------------------继承Thread类创建线程---------------------

    通过继承Thread类来创建并启动多线程的一般步骤如下

    1】d定义Thread类的子类,并重写该类的run()方法,该方法的方法体就是线程需要完成的任务,run()方法也称为线程执行体。

    2】创建Thread子类的实例,也就是创建了线程对象

    3】启动线程,即调用线程的start()方法

    代码实例

    public class MyThread extends Thread{//继承Thread类

      public void run(){

      //重写run方法

      }

    }

    public class Main {

      public static void main(String[] args){

        new MyThread().start();//创建并启动线程

      }

    }

    ------------------------实现Runnable接口创建线程---------------------

    通过实现Runnable接口创建并启动线程一般步骤如下:

    1】定义Runnable接口的实现类,一样要重写run()方法,这个run()方法和Thread中的run()方法一样是线程的执行体

    2】创建Runnable实现类的实例,并用这个实例作为Thread的target来创建Thread对象,这个Thread对象才是真正的线程对象

    3】第三部依然是通过调用线程对象的start()方法来启动线程

    代码实例:

    public class MyThread2 implements Runnable {//实现Runnable接口

      public void run(){

      //重写run方法

      }

    }

    public class Main {

      public static void main(String[] args){

        //创建并启动线程

        MyThread2 myThread=new MyThread2();

        Thread thread=new Thread(myThread);

        thread().start();

        //或者    new Thread(new MyThread2()).start();

      }

    }

    ------------------------使用Callable和Future创建线程---------------------

    和Runnable接口不一样,Callable接口提供了一个call()方法作为线程执行体,call()方法比run()方法功能要强大。

    》call()方法可以有返回值

    》call()方法可以声明抛出异常

    Java5提供了Future接口来代表Callable接口里call()方法的返回值,并且为Future接口提供了一个实现类FutureTask,这个实现类既实现了Future接口,还实现了Runnable接口,因此可以作为Thread类的target。在Future接口里定义了几个公共方法来控制它关联的Callable任务。

    >boolean cancel(boolean mayInterruptIfRunning):视图取消该Future里面关联的Callable任务

    >V get():返回Callable里call()方法的返回值,调用这个方法会导致程序阻塞,必须等到子线程结束后才会得到返回值

    >V get(long timeout,TimeUnit unit):返回Callable里call()方法的返回值,最多阻塞timeout时间,经过指定时间没有返回抛出TimeoutException

    >boolean isDone():若Callable任务完成,返回True

    >boolean isCancelled():如果在Callable任务正常完成前被取消,返回True

    介绍了相关的概念之后,创建并启动有返回值的线程的步骤如下:

    1】创建Callable接口的实现类,并实现call()方法,然后创建该实现类的实例(从java8开始可以直接使用Lambda表达式创建Callable对象)。

    2】使用FutureTask类来包装Callable对象,该FutureTask对象封装了Callable对象的call()方法的返回值

    3】使用FutureTask对象作为Thread对象的target创建并启动线程(因为FutureTask实现了Runnable接口)

    4】调用FutureTask对象的get()方法来获得子线程执行结束后的返回值

    代码实例:

    public class Main {

      public static void main(String[] args){

       MyThread3 th=new MyThread3();

       //使用Lambda表达式创建Callable对象

         //使用FutureTask类来包装Callable对象

       FutureTask<Integer> future=new FutureTask<Integer>(

        (Callable<Integer>)()->{

          return 5;

        }

        );

       new Thread(task,"有返回值的线程").start();//实质上还是以Callable对象来创建并启动线程

        try{

        System.out.println("子线程的返回值:"+future.get());//get()方法会阻塞,直到子线程执行结束才返回

        }catch(Exception e){

        ex.printStackTrace();

       }

      }

    }

    ------------------------使用线程池例如用Executor框架---------------------

    1.5后引入的Executor框架的最大优点是把任务的提交和执行解耦。要执行任务的人只需把Task描述清楚,然后提交即可。这个Task是怎么被执行的,被谁执行的,什么时候执行的,提交的人就不用关心了。具体点讲,提交一个Callable对象给ExecutorService(如最常用的线程池ThreadPoolExecutor),将得到一个Future对象,调用Future对象的get方法等待执行结果就好了。Executor框架的内部使用了线程池机制,它在java.util.cocurrent 包下,通过该框架来控制线程的启动、执行和关闭,可以简化并发编程的操作。因此,在Java 5之后,通过Executor来启动线程比使用Thread的start方法更好,除了更易管理,效率更好(用线程池实现,节约开销)外,还有关键的一点:有助于避免this逃逸问题——如果我们在构造器中启动一个线程,因为另一个任务可能会在构造器结束之前开始执行,此时可能会访问到初始化了一半的对象用Executor在构造器中。

        Executor框架包括:线程池,Executor,Executors,ExecutorService,CompletionService,Future,Callable等。

        Executor接口中之定义了一个方法execute(Runnable command),该方法接收一个Runable实例,它用来执行一个任务,任务即一个实现了Runnable接口的类。ExecutorService接口继承自Executor接口,它提供了更丰富的实现多线程的方法,比如,ExecutorService提供了关闭自己的方法,以及可为跟踪一个或多个异步任务执行状况而生成 Future 的方法。 可以调用ExecutorService的shutdown()方法来平滑地关闭 ExecutorService,调用该方法后,将导致ExecutorService停止接受任何新的任务且等待已经提交的任务执行完成(已经提交的任务会分两类:一类是已经在执行的,另一类是还没有开始执行的),当所有已经提交的任务执行完毕后将会关闭ExecutorService。因此我们一般用该接口来实现和管理多线程。

        ExecutorService的生命周期包括三种状态:运行、关闭、终止。创建后便进入运行状态,当调用了shutdown()方法时,便进入关闭状态,此时意味着ExecutorService不再接受新的任务,但它还在执行已经提交了的任务,当素有已经提交了的任务执行完后,便到达终止状态。如果不调用shutdown()方法,ExecutorService会一直处在运行状态,不断接收新的任务,执行新的任务,服务器端一般不需要关闭它,保持一直运行即可。

        Executors提供了一系列工厂方法用于创先线程池,返回的线程池都实现了ExecutorService接口。   

        public static ExecutorService newFixedThreadPool(int nThreads)

        创建固定数目线程的线程池。

        public static ExecutorService newCachedThreadPool()

        创建一个可缓存的线程池,调用execute将重用以前构造的线程(如果线程可用)。如果现有线程没有可用的,则创建一个新线   程并添加到池中。终止并从缓存中移除那些已有 60 秒钟未被使用的线程。

        public static ExecutorService newSingleThreadExecutor()

        创建一个单线程化的Executor。

        public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize)

        创建一个支持定时及周期性的任务执行的线程池,多数情况下可用来替代Timer类。

        这四种方法都是用的Executors中的ThreadFactory建立的线程,下面就以上四个方法做个比较




    newCachedThreadPool()                                                                                                                                         

    -缓存型池子,先查看池中有没有以前建立的线程,如果有,就 reuse.如果没有,就建一个新的线程加入池中
    -缓存型池子通常用于执行一些生存期很短的异步型任务
     因此在一些面向连接的daemon型SERVER中用得不多。但对于生存期短的异步任务,它是Executor的首选。
    -能reuse的线程,必须是timeout IDLE内的池中线程,缺省     timeout是60s,超过这个IDLE时长,线程实例将被终止及移出池。
      注意,放入CachedThreadPool的线程不必担心其结束,超过TIMEOUT不活动,其会自动被终止。
     


    newFixedThreadPool(int)                                                      

    -newFixedThreadPool与cacheThreadPool差不多,也是能reuse就用,但不能随时建新的线程
    -其独特之处:任意时间点,最多只能有固定数目的活动线程存在,此时如果有新的线程要建立,只能放在另外的队列中等待直到当前的线程中某个线程终止直接被移出池子
    -和cacheThreadPool不同,FixedThreadPool没有IDLE机制(可能也有,但既然文档没提,肯定非常长,类似依赖上层的TCP或UDP IDLE机制之类的),所以FixedThreadPool多数针对一些很稳定很固定的正规并发线程,多用于服务器
    -从方法的源代码看,cache池和fixed 池调用的是同一个底层 池,只不过参数不同:
    fixed池线程数固定,并且是0秒IDLE(无IDLE)    
    cache池线程数支持0-Integer.MAX_VALUE(显然完全没考虑主机的资源承受能力),60秒IDLE  

     
    newScheduledThreadPool(int)
    -调度型线程池
    -这个池子里的线程可以按schedule依次delay执行,或周期执行
     
    SingleThreadExecutor()
    -单例线程,任意时间池中只能有一个线程
    -用的是和cache池和fixed池相同的底层池,但线程数目是1-1,0秒IDLE(无IDLE)

     

        一般来说,CachedTheadPool在程序执行过程中通常会创建与所需数量相同的线程,然后在它回收旧线程时停止创建新线程,因此它是合理的Executor的首选,只有当这种方式会引发问题时(比如需要大量长时间面向连接的线程时),才需要考虑用FixedThreadPool。(该段话摘自《Thinking in Java》第四版)

                             

    Executor执行Runnable任务

        通过Executors的以上四个静态工厂方法获得 ExecutorService实例,而后调用该实例的execute(Runnable command)方法即可。一旦Runnable任务传递到execute()方法,该方法便会自动在一个线程上

    [java] view pl
     
    import java.util.concurrent.ExecutorService;   
    import java.util.concurrent.Executors;   
      
    public class TestCachedThreadPool{   
        public static void main(String[] args){   
            ExecutorService executorService = Executors.newCachedThreadPool();   
    //      ExecutorService executorService = Executors.newFixedThreadPool(5);  
    //      ExecutorService executorService = Executors.newSingleThreadExecutor();  
            for (int i = 0; i < 5; i++){   
                executorService.execute(new TestRunnable());   
                System.out.println("************* a" + i + " *************");   
            }   
            executorService.shutdown();   
        }   
    }   
      
    class TestRunnable implements Runnable{   
        public void run(){   
            System.out.println(Thread.currentThread().getName() + "线程被调用了。");   
        }   
    }  

       某次执行后的结果如下:

       从结果中可以看出,pool-1-thread-1和pool-1-thread-2均被调用了两次,这是随机的,execute会首先在线程池中选择一个已有空闲线程来执行任务,如果线程池中没有空闲线程,它便会创建一个新的线程来执行任务。

    Executor执行Callable任务

        在Java 5之后,任务分两类:一类是实现了Runnable接口的类,一类是实现了Callable接口的类。两者都可以被ExecutorService执行,但是Runnable任务没有返回值,而Callable任务有返回值。并且Callable的call()方法只能通过ExecutorService的submit(Callable<T> task) 方法来执行,并且返回一个 <T>Future<T>,是表示任务等待完成的 Future。

        Callable接口类似于Runnable,两者都是为那些其实例可能被另一个线程执行的类设计的。但是 Runnable 不会返回结果,并且无法抛出经过检查的异常而Callable又返回结果,而且当获取返回结果时可能会抛出异常。Callable中的call()方法类似Runnable的run()方法,区别同样是有返回值,后者没有。

        当将一个Callable的对象传递给ExecutorService的submit方法,则该call方法自动在一个线程上执行,并且会返回执行结果Future对象。同样,将Runnable的对象传递给ExecutorService的submit方法,则该run方法自动在一个线程上执行,并且会返回执行结果Future对象,但是在该Future对象上调用get方法,将返回null。

        下面给出一个Executor执行Callable任务的示例代码:

    import java.util.ArrayList;   
    import java.util.List;   
    import java.util.concurrent.*;   
      
    public class CallableDemo{   
        public static void main(String[] args){   
            ExecutorService executorService = Executors.newCachedThreadPool();   
            List<Future<String>> resultList = new ArrayList<Future<String>>();   
      
            //创建10个任务并执行   
            for (int i = 0; i < 10; i++){   
                //使用ExecutorService执行Callable类型的任务,并将结果保存在future变量中   
                Future<String> future = executorService.submit(new TaskWithResult(i));   
                //将任务执行结果存储到List中   
                resultList.add(future);   
            }   
      
            //遍历任务的结果   
            for (Future<String> fs : resultList){   
                    try{   
                        while(!fs.isDone);//Future返回如果没有完成,则一直循环等待,直到Future返回完成  
                        System.out.println(fs.get());     //打印各个线程(任务)执行的结果   
                    }catch(InterruptedException e){   
                        e.printStackTrace();   
                    }catch(ExecutionException e){   
                        e.printStackTrace();   
                    }finally{   
                        //启动一次顺序关闭,执行以前提交的任务,但不接受新任务  
                        executorService.shutdown();   
                    }   
            }   
        }   
    }   
      
      
    class TaskWithResult implements Callable<String>{   
        private int id;   
      
        public TaskWithResult(int id){   
            this.id = id;   
        }   
      
        /**  
         * 任务的具体过程,一旦任务传给ExecutorService的submit方法, 
         * 则该方法自动在一个线程上执行 
         */   
        public String call() throws Exception {  
            System.out.println("call()方法被自动调用!!!    " + Thread.currentThread().getName());   
            //该返回结果将被Future的get方法得到  
            return "call()方法被自动调用,任务返回的结果是:" + id + "    " + Thread.currentThread().getName();   
        }   
    }  

        某次执行结果如下:

       

        从结果中可以同样可以看出,submit也是首先选择空闲线程来执行任务,如果没有,才会创建新的线程来执行任务。另外,需要注意:如果Future的返回尚未完成,则get()方法会阻塞等待,直到Future完成返回,可以通过调用isDone()方法判断Future是否完成了返回。

    自定义线程池

        自定义线程池,可以用ThreadPoolExecutor类创建,它有多个构造方法来创建线程池,用该类很容易实现自定义的线程池,这里先贴上示例程序:

    import java.util.concurrent.ArrayBlockingQueue;   
    import java.util.concurrent.BlockingQueue;   
    import java.util.concurrent.ThreadPoolExecutor;   
    import java.util.concurrent.TimeUnit;   
      
    public class ThreadPoolTest{   
        public static void main(String[] args){   
            //创建等待队列   
            BlockingQueue<Runnable> bqueue = new ArrayBlockingQueue<Runnable>(20);   
            //创建线程池,池中保存的线程数为3,允许的最大线程数为5  
            ThreadPoolExecutor pool = new ThreadPoolExecutor(3,5,50,TimeUnit.MILLISECONDS,bqueue);   
            //创建七个任务   
            Runnable t1 = new MyThread();   
            Runnable t2 = new MyThread();   
            Runnable t3 = new MyThread();   
            Runnable t4 = new MyThread();   
            Runnable t5 = new MyThread();   
            Runnable t6 = new MyThread();   
            Runnable t7 = new MyThread();   
            //每个任务会在一个线程上执行  
            pool.execute(t1);   
            pool.execute(t2);   
            pool.execute(t3);   
            pool.execute(t4);   
            pool.execute(t5);   
            pool.execute(t6);   
            pool.execute(t7);   
            //关闭线程池   
            pool.shutdown();   
        }   
    }   
      
    class MyThread implements Runnable{   
        @Override   
        public void run(){   
            System.out.println(Thread.currentThread().getName() + "正在执行。。。");   
            try{   
                Thread.sleep(100);   
            }catch(InterruptedException e){   
                e.printStackTrace();   
            }   
        }   
    }  

      运行结果如下:

        从结果中可以看出,七个任务是在线程池的三个线程上执行的。这里简要说明下用到的ThreadPoolExecuror类的构造方法中各个参数的含义。   

    public ThreadPoolExecutor (int corePoolSize, int maximumPoolSize, long         keepAliveTime, TimeUnit unit,BlockingQueue<Runnable> workQueue)

    corePoolSize:线程池中所保存的线程数,包括空闲线程。

    maximumPoolSize:池中允许的最大线程数。

    keepAliveTime:当线程数大于核心数时,该参数为所有的任务终止前,多余的空闲线程等待新任务的最长时间。

    unit:等待时间的单位。

    workQueue:任务执行前保存任务的队列,仅保存由execute方法提交的Runnable任务。

    --------------------------------------四种创建线程方法对比--------------------------------------

    实现Runnable和实现Callable接口的方式基本相同,不过是后者执行call()方法有返回值,后者线程执行体run()方法无返回值,因此可以把这两种方式归为一种这种方式与继承Thread类的方法之间的差别如下:

    1、线程只是实现Runnable或实现Callable接口,还可以继承其他类。

    2、这种方式下,多个线程可以共享一个target对象,非常适合多线程处理同一份资源的情形。

    3、但是编程稍微复杂,如果需要访问当前线程,必须调用Thread.currentThread()方法。

    4、继承Thread类的线程类不能再继承其他父类(Java单继承决定)。

    5、前三种的线程如果创建关闭频繁会消耗系统资源影响性能,而使用线程池可以不用线程的时候放回线程池,用的时候再从线程池取,项目开发中主要使用线程池

    注:在前三种中一般推荐采用实现接口的方式来创建多线程

    创建线程本质只有1种,即创建Thread类,以上的所谓创建方式其实是实现run方法的方式:

    实现run方法的方式分为两类,你所看到的其他的都是对这两类的封装:

    1、实现runnable接口的run方法,并把runnable实例作为target对象,传给thread类,最终调用target.run

    2、继承Thread类,重写Thread的run方法,Thread.start会执行run方法

    展开全文
  • 一般情况,我们实现多线程都是Thread或者Runnable(后者... * 假如Thread1、Thread2、ThreaD3、Thread4四条线程分别统计C、D、E、F四个盘的大小,所有线程都统计完毕交给Thread5线程去做汇总,应当如何实现? *...
  • public class Test04 implements Runnable { private static int count=0; @Override ...// System.out.print("线程1:"); tt.start(); tt2.start(); tt3.start(); tt4.start(); } }
  • * 4个线程分别获取C、D、E、F盘的大小,第5个线程统计总大小 */ public class Question_01 { public static void main(String[] args) { ExecutorService executorService = Executors.newFixedThreadPool(4)...
  • Java多线程,启动四个线程,两个执行加一,另外两个执行减一
  • 这是一道典型的java多线程面试题。...进行,多进程之间的数据资源和地址空间是共享的,所以为了避免各种可预见和不可预见的错误发生,我们一般都都会给线程间加同步或者互斥进行处理。 java中实现
  • System.out.println("线程" + Thread.currentThread().getName() + "A" + i); } private synchronized void reduce() { // TODO Auto-generated method stub i--; System.out.println("线程" + Thread....
  • 用CountDownLatch : 一个线程(或者多个), 等待另外N个线程完成某个事情之后才能执行 CountDownLatch 是计数器, 线程完成一个就记一个, 就像 报数一样, 只不过是递减的. 盗用别人的一个例子: public ...
  • 四核八线程

    千次阅读 2018-10-05 19:10:41
    四核八线程   四个物理核心,模拟成八个逻辑核心。 因为使用了超线程技术 , 把一个物理核心模拟成两个逻辑核心, 就像八个物理核心一样在同一时间可以执行八个线程。  ...
  • 需求是开四个线程访问一个Vector(因为Vector是线程安全的),取得Vector的信息,这个信息是要一段时间进行处理,就是说,取得信息访问之后,可能这个信息还没有处理完,所以要先等一等,先取得取得Vector下一个元素再...
  • (Google面试题)有四个线程1、2、3、4。线程1的功能就是输出1,线程2的功能就是输出2,以此类推.........现在四个文件ABCD。初始都为空。 现要让四个文件呈如下格式: A:1 2 3 4 1 2.... B:2 3 4 1 2 3......
  • 前言:之前看到一Java的面试题,最近在看《Java多线程编程核心技术》然后就试着去解决这道题,这里给出一个人认为最简单的方法:主要用到的方法是:CountDownLatch, CountDownLatch类是一同步倒数计数器,...
  • 有四个线程1、2、3、4。线程1的功能就是输出1,线程2的功能就是输出2,以此类推.........现在四个文件ABCD。初始都为空。现要让四个文件呈如下格式:A:1 2 3 4 1 2....B:2 3 4 1 2 3....C:3 4 1 2 3 4....D:4 ...
  • 四个线程在卖100张票

    千次阅读 2012-08-17 10:35:15
    package ... /** * 四个线程在卖100张票 * @author Kevin * */ public class Test { public static void main(String[] args) { new TestThread().start(); new TestThread().start
  • 说说四核八线程

    千次阅读 2016-10-28 22:13:04
    这年头卖电脑的都说咱家这个...这就有点奇怪了,既然是四个cpu应该并行运行四个线程才对,为什么是八个?? 可以这样来理解,四核相当于四条大而宽的道路,八线程就是将每一个宽道路用线划成两个分支,这样,就可以供
  • 说明:MyObj类为功能函数(加1和减1)以及变量i的存储地方。...假设每个线程处理3次 public class Main { public static void main(String[] args){ MyObj myObj = new MyObj(); for(int i=0; i<...
  • java多线程顺序打印ABCD四个字母

    千次阅读 2017-07-05 18:05:23
    我最近意识到自己java多线程这块需要好好学习一下,下面是我实现的java通4个线程顺序打印ABCD四个字母,第一个线程打印A,第二个线程打印B,第三个线程打印C,第四个线程打印D。 我说一下我的思路,应为都是打印,...
  • 碰到这个面试提后,不是做不出来,而是不想去自己想.原本在网上搜一下算了,但是看了不下10个答案,全nm是一样的代码,就连注释都是一样的,很不爽!于是自己写了一下.... // 用java写一个多线程程序,如四个线程
  • 四个线程A、B、C、D向四个文件写入数据。要求A线程只写入A,B线程只写入B…… 最终达到的效果: A.txt内容为: A B C D A B C D…… B.txt内容为: B C D A B C D A…… C.txt内容为: C D ...
  • * 四个线程,a b c d ,共享一个变量 i ab 为加线程, cd 为减线程,四个线程执行顺序为 abcd,且输出为 0 1 2 1 0 1 2 1 0 * 1..... 共享一个变量,我们可以加一个锁就够了,关键是什么执行,什么时候等待 * 其中...
  • 昨天的面试题(天元网络)  两问题:  ... * 加一线程与减一线程共同操作一数 * 两问题: * 1、线程同步--synchronized * 2、线程之间如何共享同一j变量--内部类 * @author liuwe
  • 理解了线程同步和线程通信之后,再来看本文的知识点就会简单的多了,本文是做为传统线程知识点的一补充。人会问:JDK5之后了更完善的处理多线程问题的类(并发包),我们还需要去了解传统线程吗?答:需要。
  • 如果不加synchronized()同步锁,则会出现两窗口卖了一张票 多线程的类 代码如下 public class SellTicktDemo implements Runnable { //定义总票数 private int total =100; //定义编号 private int no = total+1...
  • public class Test { public static void main(String[] args) { final ShareData data = new ShareData(); for (int i = 0; i &lt; 2; i++) { new Thread(new Runnable() { ... ...
  • 秒杀多线程篇 一经典的多线程同步问题

    万次阅读 多人点赞 2012-04-10 09:57:02
    问题涉及到线程的同步和互斥,是一道非常代表性的多线程同步问题,如果能将这问题搞清楚,那么对多线程同步也就打下了良好的基础。 程序描述:主线程启动10个子线程并将表示子线程序号的变量地址作为参数...

空空如也

空空如也

1 2 3 4 5 ... 20
收藏数 723,929
精华内容 289,571
关键字:

有四个线程分别