【Java】创建多线程的四种方式

//自定义线程类
public class MyThread extends Thread {

	// 共享数据要放在run()方法外边才能被共享且声明为static，否则就是每个线程都会调用run()方法，都会单独拥有一个run()方法里的独享数据，而非共享数据
	//eg: static int trick = 100;
    //定义指定线程名称的构造方法
    public MyThread(String name) {
        //调用父类的String参数的构造方法，指定线程的名称
        super(name);
    }
    /**
     * 重写run方法，完成该线程执行的逻辑
     */
    @Override
    public void run() {
        // 执行的操作
    }
}

public class TestMyThread {
    public static void main(String[] args) {
        //创建自定义线程对象1
        MyThread mt1 = new MyThread("子线程1");
        //开启子线程1
        mt1.start();
        
        //创建自定义线程对象2，分别创建对象开启线程，不可以数据共享，若要共享需要创建static变量
        MyThread mt2 = new MyThread("子线程2");
        //开启子线程2
        mt2.start();
    }
}

// 创建Thread类的匿名子类的匿名对象，并启动线程
new Thread(){
	public void run(){
		// 执行的操作
	}
}.strat(); // 启动线程

public class MyRunnable implements Runnable {

	// 共享数据要放在run()方法外边才能被共享，否则就是每个线程都会调用run()方法，都会单独拥有一个run()方法里的独享数据，而非共享数据
	//eg: int trick = 100;
    @Override
    public void run() {
        // 执行的操作
    }
}

public class TestMyRunnable {
    public static void main(String[] args) {
        //创建自定义类对象  线程任务对象
        MyRunnable mr = new MyRunnable();
        //创建线程对象1
        Thread t1 = new Thread(mr, "长江1");
        t1.start();

		//创建线程对象2，注意两个线程传入的是同一个对象，可以实现数据共享
        Thread t2 = new Thread(mr, "长江2");
        t2.start();
    }
}

new Thread(new Runnable(){
	public run(){
		// 执行的操作
	}
}).start(); // 开启线程

/**
*	1.同步监视器，俗称锁。哪个线程获得了锁，哪个线程就能执行该代码块
*	2.同步监视器可以是任何一个类的对象。但是，多个线程必须共用同一个同步监视器，且该对象是唯一的（只有一个实例对象）。
*		>可以自定义一个专用于线程锁的类，然后在这里创建对象作为锁使用。
*		>可以使用this充当锁，this指向当前对象。但是要注意当前类是否只创建了一个对象（保证唯一性）
*			>在继承Thread的方式中不可以使用this，因为每一个线程都需要创建对象，不满足唯一性
*			>在继承Thread的方式中，创建对象作为锁也需要声明为static的才可以，static Object obj = new Pbject();
*			>可以使用“当前类.class”充当锁。因为“Class clz = 类.class”是一个类，仅加载一次，是全局唯一的（反射），该方式在实现Runnable中也可以使用
*	
*/
synchronized(同步监视器){
	// 需要被同步的代码，即操作共享数据的代码
}

/*
*用synchronized 直接修饰操作同步代码的方法
*	1.在非static的方法中，默认锁是：this。锁无法修改，因而在继承Thread方法中不适用，可以改成同步代码块方式，手动添加将当前类做为锁
*	2.在static的方法中，默认的锁是：当前类.class。即当前类本身。
*	
*/
// 示例代码：在run()方法中调用show()方法
public synchronized void show(){
	// 操作共享数据的代码
}

class A{
    //1. 创建Lock的实例，必须确保多个线程共享同一个Lock实例，所以必须是static的，可以在加上final不让后续线程修改
	private static final ReentrantLock lock = new ReenTrantLock();
	public void m(){
        //2. 调动lock()，实现需共享的代码的锁定
		lock.lock();
		try{
			//保证线程安全的代码
		}finally{
            //3. 调用unlock()，释放共享代码的锁定。如果同步代码有异常，要将unlock()写入finally语句块，因为需要保证一定能解锁。
			lock.unlock();  
		}
	}
}

/*
 * 创建多线程的方式三：实现Callable （jdk5.0新增的）
 */
//1.创建一个实现Callable的实现类
class NumThread implements Callable {
    //2.实现call方法，将此线程需要执行的操作声明在call()中
    @Override
    public Object call() throws Exception {
        int sum = 0;
        for (int i = 1; i <= 100; i++) {
            if (i % 2 == 0) {
                System.out.println(i);
                sum += i;
            }
        }
        return sum;
    }
}


public class CallableTest {
    public static void main(String[] args) {
        //3.创建Callable接口实现类的对象
        NumThread numThread = new NumThread();

        //4.将此Callable接口实现类的对象作为传递到FutureTask构造器中，创建FutureTask的对象
        FutureTask futureTask = new FutureTask(numThread);
        //5.将FutureTask的对象作为参数传递到Thread类的构造器中，创建Thread对象，并调用start()
        new Thread(futureTask).start();


//      接收返回值
        try {
            //6.获取Callable中call方法的返回值
            //get()返回值即为FutureTask构造器参数Callable实现类重写的call()的返回值。
            Object sum = futureTask.get();
            System.out.println("总和为：" + sum);
        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (ExecutionException e) {
            e.printStackTrace();
        }
    }

}

// 这里使用实现Runnable的方式
class NumberThread implements Runnable{

    @Override
    public void run() {
        for(int i = 0;i <= 100;i++){
            if(i % 2 == 0){
                System.out.println(Thread.currentThread().getName() + ": " + i);
            }
        }
    }
}

class NumberThread1 implements Runnable{

    @Override
    public void run() {
        for(int i = 0;i <= 100;i++){
            if(i % 2 != 0){
                System.out.println(Thread.currentThread().getName() + ": " + i);
            }
        }
    }
}

class NumberThread2 implements Callable {
    @Override
    public Object call() throws Exception {
        int evenSum = 0;//记录偶数的和
        for(int i = 0;i <= 100;i++){
            if(i % 2 == 0){
                evenSum += i;
            }
        }
        return evenSum;
    }

}

public class ThreadPoolTest {

    public static void main(String[] args) {
        //1. 提供指定线程数量的线程池
        ExecutorService service = Executors.newFixedThreadPool(10);
        ThreadPoolExecutor service1 = (ThreadPoolExecutor) service;
//        //设置线程池的属性
//        System.out.println(service.getClass());//ThreadPoolExecutor
        service1.setMaximumPoolSize(50); //设置线程池中线程数的上限

        //2.执行指定的线程的操作。需要提供实现Runnable接口或Callable接口实现类的对象
        service.execute(new NumberThread());//适合适用于Runnable
        service.execute(new NumberThread1());//适合适用于Runnable

        try {
            Future future = service.submit(new NumberThread2());//适合使用于Callable
            System.out.println("总和为：" + future.get());
        } catch (Exception e) {
            e.printStackTrace();
        }
        //3.关闭连接池
        service.shutdown();
    }

}