Java之线程编程的4种方法实现案例讲解

public class T4 {

     public static void main(String[] args) {

         System.out.println(Thread.currentThread());

         Thread t1 = new A1();

         t1.start();

     }

}

class A1 extends Thread{

     @Override

     public void run() {

         for ( int i= 0 ;i< 10 ;i++) {

             System.out.println( "Thread:" +Thread.currentThread().getName());

         }

     }

}

public class T3 {

     public static void main(String[] args) {

         System.out.println( "Thread:" +Thread.currentThread().getName());

         Thread t1 = new Thread( new A2());

         t1.start();

     }

}

class A2 implements Runnable{

     @Override

     public void run() {

         int res = 0 ;

         for ( int i= 0 ;i< 10 ;i++) {

             res+=i;

         System.out.println( "Thread:" +Thread.currentThread().getName());

         }

     }

}

import java.util.concurrent.Callable;

import java.util.concurrent.FutureTask;

public class T2 {

     public static void main(String[] args) throws Exception {

         System.out.println( "Test3:" + Thread.currentThread().getName());

         Callable c = new A4();

         FutureTask ft = new FutureTask(c);

         Thread t1 = new Thread(ft);

         t1.start();

         Object res = ft.get();

         System.out.println( "结果:" + res);

     }

}

class A4 implements Callable {

     @Override

     public Object call() throws Exception {

         int res = 0 ;

         for ( int i = 0 ; i < 10 ; i++) {

             res += i;

             System.out.println( "Thread:" + Thread.currentThread().getName());

         }

         return res;

     }

}

import java.util.concurrent.Callable;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

import java.util.concurrent.Future;

public class T1 {

     public static void main(String[] args) throws Exception {

         Future[] arr = new Future[ 5 ];

         ExecutorService es = Executors.newFixedThreadPool( 3 );

         for ( int i = 0 ; i < 5 ; i++) {

             arr[i] = es.submit( new A4());

         }

         for (Future f : arr) {

             Object res = f.get();

             System.out.println( "结果为：" + res);

         }

         es.shutdown();

     }

}

class A4 implements Callable {

     @Override

     public Object call() throws Exception {

         int res = 0 ;

         for ( int i = 0 ; i < 10 ; i++) {

             res += i;

             System.out.println( "Thread" + Thread.currentThread().getName());

         }

         return res;

     }

}