java基础巩固笔记(5)-多线程之传统多线程

java基础巩固笔记(5)-多线程之传统多线程

传统线程技术

传统创建线程方式

[code]Thread t = new Thread();
t.start();

Runnable

target

Thread

Runnable

target

run

Thread

Runnable

start

Thread

start

start0

run

target.run

Thread

run

[code]public void run() {
    if (target != null) {
        target.run();
    }
}

Thread

target

[code]/* What will be run. */
private Runnable target;

target

private void init(ThreadGroup g, Runnable target, String name,long stackSize, AccessControlContext acc)

init

Thread

传统定时器技术

[code]static int count = 0;
public static void main(String[] args) {

    class MyTimerTask extends TimerTask{

        @Override
        public void run() {
            System.out.println(Thread.currentThread()+" bomb!");
            new Timer().schedule(new MyTimerTask(), 2000+1000*(count++%2));
        }
    }
    //3s后开启定时器
    new Timer().schedule(new MyTimerTask(),3000);
}

quarlz

互斥

synchronized

synchronized(this)

synchronized void function(){}

synchronized(A.class)

同步

[code]/**
 * Created by brian on 2016/2/4.
 */
public class TraditionalThreadCommunication {
    public static void main(String[] args) {
        Business business = new Business();
        new Thread(
                new Runnable() {
                    @Override
                    public void run() {
                        for(int i=1;i<=50;i++){
                            business.sub(i);
                        }
                    }
                }
        ).start();

        for(int i=1;i<=50;i++){
            business.main(i);
        }

    }
}

class Business{
    private boolean bShouldSub = true;

    public synchronized void sub(int i){
        while(!bShouldSub){
            try {
                this.wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        for(int j=1;j<=5;j++){
            System.out.println("sub thread count "+j+","+i+"/50");
        }
        bShouldSub = false;
        this.notify();
    }
    public synchronized void main(int i){
        while(bShouldSub){
            try {
                this.wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        for(int j=1;j<=10;j++){
            System.out.println("main thread count "+j+","+i+"/50");
        }
        bShouldSub = true;
        this.notify();
    }
}