多線程編程面試題

public class ABC_Condition {
    private static Lock lock=new ReentrantLock();
    private static Condition con1=lock.newCondition();
    private static Condition con2=lock.newCondition();
    private static Condition con3=lock.newCondition();
    
    private static int count=0;
    static class ThreadA extends Thread {
        @Override
        public void run() {
            try {
                lock.lock();
                for(int i=0;i<10;i++) {
                    while(count%3==0) {
                        con1.await();
                        System.out.println("A");
                        count++;
                        con2.signal();
                    }
                }
            }catch(InterruptedException e) {
                e.printStackTrace();
            }finally {
                lock.unlock();
            }
        }
    }
    
    static class ThreadB extends Thread {
        @Override
        public void run() {
            try {
                lock.lock();
                for(int i=0;i<10;i++) {
                    while(count%3==1) {
                        con2.await();
                        System.out.println("B");
                        count++;
                        con3.signal();
                    }
                }
            }catch(InterruptedException e) {
                e.printStackTrace();
            }finally {
                lock.unlock();
            }
        }
    }
    
    static class ThreadC extends Thread {
        @Override
        public void run() {
            try {
                lock.lock();
                for(int i=0;i<10;i++) {
                    while(count%3==2) {
                        con3.await();
                        System.out.println("C");
                        count++;
                        con1.signal();
                    }
                }
            }catch(InterruptedException e) {
                e.printStackTrace();
            }finally {
                lock.unlock();
            }
        }
    }
    
    public static void main(String[] args) throws InterruptedException {
        new ThreadA().start();
        new ThreadB().start();
        new ThreadC().start();
        
    }
}

public class ABC_Lock {
    private static Lock lock=new ReentrantLock();
    private static int state=0;
    
    static class ThreadA extends Thread{
        @Override
        public void run() {
            for(int i=0;i<10;i++) {
                try {
                    lock.lock();
                    while(state%3==0) {
                        System.out.println("A");
                        state++;
                        i++;
                    }
                }finally {
                    lock.unlock();
                }
            }
        }
    }
    
    static class ThreadB extends Thread{
        @Override
        public void run() {
            for(int i=0;i<10;i++) {
                try {
                    lock.lock();
                    while(state%3==1) {
                        System.out.println("B");
                        state++;
                        i++;
                    }
                }finally {
                    lock.unlock();
                }
            }
        }
    }
    
    static class ThreadC extends Thread{
        @Override
        public void run() {
            for(int i=0;i<10;i++) {
                try {
                    lock.lock();
                    while(state%3==2) {
                        System.out.println("C");
                        state++;
                        i++;
                    }
                }finally {
                    lock.unlock();
                }
            }
        }
    }
    
    public static void main(String[] args) {
        new ThreadA().start();
        new ThreadB().start();
        new ThreadC().start();
    }
}

public class ConductAndConsume {
    public static void main(String[] args) {
        Student s=new Student();
        SetStudent ss=new SetStudent(s);
        GetStudent gs=new GetStudent(s);
        Thread t1=new Thread(ss,"生產(chǎn)者");
        Thread t2=new Thread(gs,"消費(fèi)者");
        t1.start();
        t2.start();
        
}
}

class Student{
    private String name;
    private int age;
    boolean flag;
    
    //生產(chǎn)者的功能，為student對象賦值
    public synchronized void set(String name,int age) {
        if(this.flag) {
            try {
                this.wait();
            }catch(InterruptedException e) {
                e.printStackTrace();
            }
        }
        this.name=name;
        this.age=age;
        this.flag=true;
        this.notify();
    }
    //消費(fèi)者的功能泌参，打印student對象
    public synchronized void get() {
        if(!this.flag) {
            try {
                this.wait();
            }catch(InterruptedException e) {
                e.printStackTrace();
            }
        }
        System.out.println(name+"  "+age);
        this.flag=false;
        this.notify();
    }
}
class SetStudent implements Runnable{
    private Student s;
    private int x=0;
    public SetStudent(Student s) {
        this.s=s;
    }
    @Override
    public void run() {
        while(true) {
            if(x%2==0) {
                s.set("zhangsan", 11);
            }else {
                s.set("lisi", 22);
            }
            x++;
        }
        
    }
}

class GetStudent implements Runnable{
    private Student s;
    public GetStudent(Student s) {
        this.s=s;
    }
    @Override
    public void run() {
        while(true) {
            s.get();
        }
        
    }
}

//設(shè)計(jì)四個(gè)線程给郊，其中兩個(gè)線程每次對變量i加1尖昏，另外兩個(gè)線程每次對i減1
public class FourProcessAddSub{
    private int i=0;
    public static void main(String[] args) {
        FourProcessAddSub fp=new FourProcessAddSub();
        Add add=fp.new Add();
        Sub sub=fp.new Sub();
        for(int i=1;i<=2;i++) {
            new Thread(add,"線程"+i).start();
            new Thread(sub,"線程"+i).start();
        }
    }


public synchronized void addOne() {
    i++;
    System.out.println(Thread.currentThread().getName()+"+1的值為："+i);
}
public synchronized void subOne() {
    i--;
    System.out.println(Thread.currentThread().getName()+"-1的值為："+i);
}
class Add implements Runnable {

    @Override
    public void run() {
        for(int i=0;i<10;i++) {
            addOne();
            try {
                Thread.sleep(100);
            }catch(InterruptedException e) {
                e.printStackTrace();
            }
        }
        
    }
  
}

class Sub implements Runnable{
    @Override
    public void run() {
        for(int i=0;i<10;i++) {
            subOne();
            try {
                Thread.sleep(100);
            }catch(InterruptedException e) {
                e.printStackTrace();
            }
        }
        
    }
}
}

//子線程循環(huán)10次勒奇，主線程循環(huán)20次硫眯，接著子線程循環(huán)10次乓旗，主線程循環(huán)20次...如此反復(fù)循環(huán)50次
public class Function {
    private boolean flag=false;
    
    Lock lock=new ReentrantLock();
    Condition con=lock.newCondition();
    
    public void sub() {
        lock.lock();
        try {
            while(flag) {
                try {
                    con.await();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }       
        }
            for(int i=0;i<10;i++) {
                System.out.println("sub:"+i);
            }
            flag=true;
            con.signal();
            }finally {
            lock.unlock();
        }
        
    }
    public synchronized void main() {
        lock.lock();
        try {
            while(!flag) {
                try {
                    con.await();
                }catch(InterruptedException e){
                    e.printStackTrace();
                }
            }
            for(int i=0;i<20;i++) {
                System.out.println("main"+i);
            }
            flag=false;
            con.signal();
        }finally {
            lock.unlock();
        }
    }
    
    

}

//用3個(gè)線程打印遞增的數(shù)
public class PrintNum3Process {
    public static void main(String[] args) {
        final Handler handler=new Handler();
        for(int i=0;i<3;i++) {
            new Thread(new Runnable() {
                
                @Override
                public void run() {
                    for(int j=0;j<5;j++) {
                        handler.print(Thread.currentThread().getName());
                    }
                    
                }
            },i+"").start();
        }
    }
}
class Handler{
    private int num=1;
    private int status=0;
    
    public synchronized void print(String nums) {
        int Index=Integer.parseInt(nums);
        while(Index!=status) {
            try {
                this.wait();
            }catch(InterruptedException e) {
                e.printStackTrace();
            }
        }
        System.out.print("Thread"+nums+":");
        for(int count =0;count<5;count++,num++) {
            if(count>0) {
                System.out.print(",");
            }
            System.out.print(num);
        }
        System.out.println();
        status=(status+1)%3;
        this.notifyAll();
    }
}

//兩個(gè)線程交替打印1-100
public class PrintOneTOHundred implements Runnable {
    //設(shè)置一個(gè)全局變量禽最，兩個(gè)線程先后訪問這個(gè)變量
    int i=1;
    @Override
    public void run() {
        // TODO Auto-generated method stub
        while(true) {
            synchronized(this) {
                notify();
                try {
                    Thread.currentThread().sleep(100);
                }catch(InterruptedException e) {
                    e.printStackTrace();
                }
                if(i<=100) {
                    System.out.println(Thread.currentThread().getName()+":"+i);
                    i++;
                    try {
                        wait();
                    }catch(InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            }
        }
    }
    public static void main(String[] args) {
        PrintOneTOHundred p=new PrintOneTOHundred();
        Thread t1=new Thread(p);
        Thread t2=new Thread(p);
        t1.setName("線程1");
        t2.setName("線程2");
        t1.start();
        t2.start();
    }
}

//交替打印a1b2c3d4
public class PrintTwoNum {
 static final Object object=new Object();
 public static void main(String[] args) {
    new Thread(new Runnable() {
        String a[]= {"a","b","c","d"};
        @Override
        public void run() {
            for(int i=0;i<4;i++) {
                synchronized(object) {
                    object.notify();
                    try {
                        object.wait();
                    }catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    System.out.println(a[i]);
                    object.notify();
                }
            }
            
        }
    }).start();
    new Thread(new Runnable() {
        int a[]= {1,2,3,4};
        @Override
        public void run() {
            for(int i=0;i<4;i++) {
                synchronized(object) {
                    object.notify();
                    try {
                        object.wait();
                    }catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    System.out.println(a[i]);
                    
                }
            }
        }
    }).start();
}
}

/*
 * 現(xiàn)有的程序代碼模擬產(chǎn)生了16個(gè)日志對象，
 * 并且需要運(yùn)行16秒琳拨，才能打印完這些日志瞭恰，
 * 請?jiān)诔绦蛑性黾?個(gè)線程去調(diào)用parseLog()方法來分頭打印這16個(gè)日志對象屯曹，
 * 程序只需要運(yùn)行4秒即可打印完這些日志對象
 */
public class ProcessLog {
    public static void main(String[] args) {
        final BlockingQueue<String> quene=new ArrayBlockingQueue<>(16);
        for(int i=0;i<4;i++) {
            new Thread(new Runnable() {
                
                @Override
                public void run() {
                    while(true) {
                        try {
                            parseLog(quene.take());
                        }catch(InterruptedException e) {
                            e.printStackTrace();
                        }
                    }
                    
                }
            }).start();
        }
        System.out.println("begin:"+(System.currentTimeMillis()/1000));
        for(int i=0;i<16;i++) {
            final String log=" "+(i+1);
            {
                try {
                    quene.put(log);
                }catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
    }
    public static void parseLog(String log) {
        System.out.println(log+":"+System.currentTimeMillis()/1000);
        try {
            Thread.sleep(1000);
        }catch(InterruptedException e) {
            e.printStackTrace();
        }
    }
}

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者

人面猴
序言：七十年代末狱庇，一起剝皮案震驚了整個(gè)濱河市，隨后出現(xiàn)的幾起案子恶耽，更是在濱河造成了極大的恐慌密任，老刑警劉巖，帶你破解...
沈念sama閱讀 206,968評論 6贊 482
死咒
序言：濱河連續(xù)發(fā)生了三起死亡事件偷俭，死亡現(xiàn)場離奇詭異浪讳，居然都是意外死亡，警方通過查閱死者的電腦和手機(jī)涌萤，發(fā)現(xiàn)死者居然都...
沈念sama閱讀 88,601評論 2贊 382
救了他兩次的神仙讓他今天三更去死
文/潘曉璐我一進(jìn)店門淹遵，熙熙樓的掌柜王于貴愁眉苦臉地迎上來口猜，“玉大人，你說我怎么就攤上這事透揣〖醚祝” “怎么了？”我有些...
開封第一講書人閱讀 153,220評論 0贊 344
道士緝兇錄：失蹤的賣姜人
文/不壞的土叔我叫張陵辐真，是天一觀的道長须尚。經(jīng)常有香客問我，道長侍咱，這世上最難降的妖魔是什么耐床？我笑而不...
開封第一講書人閱讀 55,416評論 1贊 279
?港島之戀（遺憾婚禮）
正文為了忘掉前任，我火速辦了婚禮楔脯，結(jié)果婚禮上撩轰，老公的妹妹穿的比我還像新娘。我一直安慰自己昧廷，他們只是感情好钧敞，可當(dāng)我...
茶點(diǎn)故事閱讀 64,425評論 5贊 374
惡毒庶女頂嫁案：這布局不是一般人想出來的
文/花漫我一把揭開白布。她就那樣靜靜地躺著麸粮，像睡著了一般溉苛。火紅的嫁衣襯著肌膚如雪。梳的紋絲不亂的頭發(fā)上弄诲，一...
開封第一講書人閱讀 49,144評論 1贊 285
城市分裂傳說
那天愚战，我揣著相機(jī)與錄音，去河邊找鬼齐遵。笑死寂玲，一個(gè)胖子當(dāng)著我的面吹牛，可吹牛的內(nèi)容都是我干的梗摇。我是一名探鬼主播拓哟，決...
沈念sama閱讀 38,432評論 3贊 401
雙鴛鴦連環(huán)套：你想象不到人心有多黑
文/蒼蘭香墨我猛地睜開眼，長吁一口氣：“原來是場噩夢啊……” “哼伶授！你這毒婦竟也來了断序？” 一聲冷哼從身側(cè)響起，我...
開封第一講書人閱讀 37,088評論 0贊 261
萬榮殺人案實(shí)錄
序言：老撾萬榮一對情侶失蹤糜烹，失蹤者是張志新（化名）和其女友劉穎违诗，沒想到半個(gè)月后，有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體疮蹦，經(jīng)...
沈念sama閱讀 43,586評論 1贊 300
?護(hù)林員之死
正文獨(dú)居荒郊野嶺守林人離奇死亡诸迟，尸身上長有42處帶血的膿包…… 初始之章·張勛以下內(nèi)容為張勛視角年9月15日...
茶點(diǎn)故事閱讀 36,028評論 2贊 325
?白月光啟示錄
正文我和宋清朗相戀三年，在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了。大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片阵苇。...
茶點(diǎn)故事閱讀 38,137評論 1贊 334
活死人
序言：一個(gè)原本活蹦亂跳的男人離奇死亡壁公，死狀恐怖，靈堂內(nèi)的尸體忽然破棺而出绅项，到底是詐尸還是另有隱情贮尖，我是刑警寧澤，帶...
沈念sama閱讀 33,783評論 4贊 324
?日本核電站爆炸內(nèi)幕
正文年R本政府宣布趁怔，位于F島的核電站湿硝，受9級特大地震影響，放射性物質(zhì)發(fā)生泄漏润努。R本人自食惡果不足惜关斜，卻給世界環(huán)境...
茶點(diǎn)故事閱讀 39,343評論 3贊 307
男人毒藥：我在死后第九天來索命
文/蒙蒙一、第九天我趴在偏房一處隱蔽的房頂上張望铺浇。院中可真熱鬧痢畜，春花似錦、人聲如沸鳍侣。這莊子的主人今日做“春日...
開封第一講書人閱讀 30,333評論 0贊 19
一樁弒父案，背后竟有這般陰謀
文/蒼蘭香墨我抬頭看了看天上的太陽倚聚。三九已至线衫，卻和暖如春，著一層夾襖步出監(jiān)牢的瞬間惑折，已是汗流浹背授账。一陣腳步聲響...
開封第一講書人閱讀 31,559評論 1贊 262
情欲美人皮
我被黑心中介騙來泰國打工，沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留惨驶，地道東北人白热。一個(gè)月前我還...
沈念sama閱讀 45,595評論 2贊 355
代替公主和親
正文我出身青樓，卻偏偏與公主長得像粗卜，于是被迫代替她去往敵國和親屋确。傳聞我的和親對象是個(gè)殘疾皇子，可洞房花燭夜當(dāng)晚...
茶點(diǎn)故事閱讀 42,901評論 2贊 345

多線程編程面試題

推薦閱讀更多精彩內(nèi)容