Java多线程基础（二）

发布时间：2020-12-14 06:33:49 所属栏目：Java 来源：网络整理

导读：} span style="color: #0000ff;"public span style="color: #0000ff;"class span style="color: #000000;" ThreadDemo1 { /spanspan style="color: #0000ff;"gt;public/span span style="color: #0000ff;"gt;static/span span style="color: #0000ff;"gt;voi

}

public class ThreadDemo1 {

</span><span style="color: #0000ff;"&gt;public</span> <span style="color: #0000ff;"&gt;static</span> <span style="color: #0000ff;"&gt;void</span><span style="color: #000000;"&gt; main(String[] args) {
    </span><span style="color: #008000;"&gt;//</span><span style="color: #008000;"&gt; TODO Auto-generated method stub
    </span><span style="color: #008000;"&gt;//</span><span style="color: #008000;"&gt;创建共享资源对象</span>
    TicketRes ticketRes=<span style="color: #0000ff;"&gt;new</span><span style="color: #000000;"&gt; TicketRes();
    </span><span style="color: #008000;"&gt;//</span><span style="color: #008000;"&gt;创建线程对象</span>
    Thread w1=<span style="color: #0000ff;"&gt;new</span> Thread(ticketRes,"窗口1"<span style="color: #000000;"&gt;);
    Thread w2</span>=<span style="color: #0000ff;"&gt;new</span> Thread(ticketRes,"窗口2"<span style="color: #000000;"&gt;);
    Thread w3</span>=<span style="color: #0000ff;"&gt;new</span> Thread(ticketRes,"窗口3"<span style="color: #000000;"&gt;);
    w1.start();
    w2.start();
    w3.start();
}

}
//共享资源类
class TicketRes implements Runnable{
private int ticket=100;
private Object lock=new Object();//锁

@Override
public void run() {
// TODO Auto-generated method stub
while(true) {
synchronized (lock) {
if(ticket>=1) {
try {
Thread.sleep(10);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
 e.printStackTrace();
}
System.out.println(Thread.currentThread().getName()+"卖第"+ticket+"张票");
ticket--;
}else {
break;
}
}
}
}
}

public class ThreadDemo2 {

</span><span style="color: #0000ff;"&gt;public</span> <span style="color: #0000ff;"&gt;static</span> <span style="color: #0000ff;"&gt;void</span><span style="color: #000000;"&gt; main(String[] args) {
    </span><span style="color: #008000;"&gt;//</span><span style="color: #008000;"&gt; TODO Auto-generated method stub
    </span><span style="color: #008000;"&gt;//</span><span style="color: #008000;"&gt;创建共享资源对象</span>
    TicketRes1 ticketRes=<span style="color: #0000ff;"&gt;new</span><span style="color: #000000;"&gt; TicketRes1();
    </span><span style="color: #008000;"&gt;//</span><span style="color: #008000;"&gt;创建线程对象</span>
    Thread w1=<span style="color: #0000ff;"&gt;new</span> Thread(ticketRes,"窗口3"<span style="color: #000000;"&gt;);
    w1.start();
    w2.start();
    w3.start();
}

}
//共享资源类
class TicketRes1 implements Runnable{
private static int ticket=100;
private Object lock=new Object();//锁

@Override
public void run() {
// TODO Auto-generated method stub
while(true) {
if(!TicketRes1.saleTicket()) {
break;
}
}
}
public synchronized static boolean saleTicket() {
if(ticket>=1) {
try {
Thread.sleep(10);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
 e.printStackTrace();
}
System.out.println(Thread.currentThread().getName()+"卖第"+ticket+"张票");
ticket--;
return true;
}else {
return false;
}
}
}

public class DeadLock {

</span><span style="color: #0000ff;"&gt;public</span> <span style="color: #0000ff;"&gt;static</span> <span style="color: #0000ff;"&gt;void</span><span style="color: #000000;"&gt; main(String[] args) {
    </span><span style="color: #008000;"&gt;//</span><span style="color: #008000;"&gt; TODO Auto-generated method stub</span>
    DeadLockThread he=<span style="color: #0000ff;"&gt;new</span> DeadLockThread(<span style="color: #0000ff;"&gt;true</span>,"小明");<span style="color: #008000;"&gt;//</span><span style="color: #008000;"&gt;他</span>
    DeadLockThread she=<span style="color: #0000ff;"&gt;new</span> DeadLockThread(<span style="color: #0000ff;"&gt;false</span>,"小华 ");<span style="color: #008000;"&gt;//</span><span style="color: #008000;"&gt;她</span>

he.start();
she.start();
}
}
//线程
class DeadLockThread extends Thread{
boolean flag=false;
public DeadLockThread() {

}
</span><span style="color: #0000ff;"&gt;protected</span> DeadLockThread(<span style="color: #0000ff;"&gt;boolean</span><span style="color: #000000;"&gt; flag,String name) {
    </span><span style="color: #0000ff;"&gt;super</span><span style="color: #000000;"&gt;(name);
    </span><span style="color: #0000ff;"&gt;this</span>.flag=<span style="color: #000000;"&gt;flag;
}
</span><span style="color: #0000ff;"&gt;public</span> <span style="color: #0000ff;"&gt;void</span><span style="color: #000000;"&gt; run() {
    </span><span style="color: #0000ff;"&gt;while</span>(<span style="color: #0000ff;"&gt;true</span><span style="color: #000000;"&gt;) {
        </span><span style="color: #0000ff;"&gt;if</span><span style="color: #000000;"&gt;(flag) {
            </span><span style="color: #0000ff;"&gt;synchronized</span> (Lock.locka) {<span style="color: #008000;"&gt;//</span><span style="color: #008000;"&gt;他</span>
                System.out.println(Thread.currentThread().getName()+"抢到了locka"<span style="color: #000000;"&gt;);
            }
            </span><span style="color: #0000ff;"&gt;synchronized</span><span style="color: #000000;"&gt; (Lock.lockb) {
                System.out.println(Thread.currentThread().getName()</span>+"抢到了lockb"<span style="color: #000000;"&gt;);
                System.out.println(Thread.currentThread().getName()</span>+"可以上厕所了"<span style="color: #000000;"&gt;);

            }
        }</span><span style="color: #0000ff;"&gt;else</span><span style="color: #000000;"&gt; {
            </span><span style="color: #0000ff;"&gt;synchronized</span> (Lock.lockb) {<span style="color: #008000;"&gt;//</span><span style="color: #008000;"&gt;她</span>
                System.out.println(Thread.currentThread().getName()+"抢到了lockb"<span style="color: #000000;"&gt;);
            }
            </span><span style="color: #0000ff;"&gt;synchronized</span><span style="color: #000000;"&gt; (Lock.locka) {
                System.out.println(Thread.currentThread().getName()</span>+"抢到了locka"<span style="color: #000000;"&gt;);
                System.out.println(Thread.currentThread().getName()</span>+"可以上厕所了"<span style="color: #000000;"&gt;);
            }
        }
    }
}

}
//创建锁对象
class Lock{
public static Object locka=new Object();
public static Object lockb=new Object();
}

import java.util.Scanner;

public class Demo1 {

</span><span style="color: #0000ff;"&gt;public</span> <span style="color: #0000ff;"&gt;static</span> <span style="color: #0000ff;"&gt;void</span><span style="color: #000000;"&gt; main(String[] args) {
    </span><span style="color: #008000;"&gt;//</span><span style="color: #008000;"&gt; TODO Auto-generated method stub</span>
    FlagStop flagStop=<span style="color: #0000ff;"&gt;new</span> FlagStop("线程1"<span style="color: #000000;"&gt;);
    flagStop.start();
    Scanner input</span>=<span style="color: #0000ff;"&gt;new</span><span style="color: #000000;"&gt; Scanner(System.in);
    System.out.println(</span>"输入任意字符结束主线程"<span style="color: #000000;"&gt;);
    input.next();
    flagStop.flag</span>=<span style="color: #0000ff;"&gt;false</span>;<span style="color: #008000;"&gt;//</span><span style="color: #008000;"&gt;主线程修改其他线程的变量</span>
    System.out.println("主线程结束"<span style="color: #000000;"&gt;);
}

}
class FlagStop extends Thread{
//定义标志 volatile:易挥发的、不稳定的，使用volatile修饰后，获取变量不会从缓存中取，从内存中取。
volatile boolean flag=true;
public FlagStop() {
// TODO Auto-generated constructor stub
 }

</span><span style="color: #0000ff;"&gt;public</span><span style="color: #000000;"&gt; FlagStop(String name) {
    </span><span style="color: #0000ff;"&gt;super</span><span style="color: #000000;"&gt;(name);
    </span><span style="color: #008000;"&gt;//</span><span style="color: #008000;"&gt; TODO Auto-generated constructor stub</span>

}

@Override
</span><span style="color: #0000ff;"&gt;public</span> <span style="color: #0000ff;"&gt;void</span><span style="color: #000000;"&gt; run() {
    </span><span style="color: #008000;"&gt;//</span><span style="color: #008000;"&gt; TODO Auto-generated method stub</span>
    System.out.println(Thread.currentThread().getName()+"开始执行了"<span style="color: #000000;"&gt;);
    </span><span style="color: #0000ff;"&gt;while</span><span style="color: #000000;"&gt;(flag) {

    }
    System.out.println(Thread.currentThread().getName()</span>+"执行完毕"<span style="color: #000000;"&gt;);
}

}

import java.util.Scanner;

public class Demo2 {

</span><span style="color: #0000ff;"&gt;public</span> <span style="color: #0000ff;"&gt;static</span> <span style="color: #0000ff;"&gt;void</span><span style="color: #000000;"&gt; main(String[] args) {
    </span><span style="color: #008000;"&gt;//</span><span style="color: #008000;"&gt; TODO Auto-generated method stub</span>
    WordStop wordStop=<span style="color: #0000ff;"&gt;new</span> WordStop("线程1"<span style="color: #000000;"&gt;);
    wordStop.start();
    Scanner input</span>=<span style="color: #0000ff;"&gt;new</span><span style="color: #000000;"&gt; Scanner(System.in);
    System.out.println(</span>"输入任意字符结束主线程"<span style="color: #000000;"&gt;);
    input.next();
    wordStop.stop();
    wordStop.flag</span>=<span style="color: #0000ff;"&gt;false</span>;<span style="color: #008000;"&gt;//</span><span style="color: #008000;"&gt;主线程修改其他线程的变量</span>
    System.out.println("主线程结束"<span style="color: #000000;"&gt;);
}

}
class WordStop extends Thread{
//定义标志 volatile:易挥发的、不稳定的，使用volatile修饰后，获取变量不会从缓存中取，从内存中取。
volatile boolean flag=true;
public WordStop() {
// TODO Auto-generated constructor stub
 }

</span><span style="color: #0000ff;"&gt;public</span><span style="color: #000000;"&gt; WordStop(String name) {
    </span><span style="color: #0000ff;"&gt;super</span><span style="color: #000000;"&gt;(name);
    </span><span style="color: #008000;"&gt;//</span><span style="color: #008000;"&gt; TODO Auto-generated constructor stub</span>

}

@Override
</span><span style="color: #0000ff;"&gt;public</span> <span style="color: #0000ff;"&gt;void</span><span style="color: #000000;"&gt; run() {
    </span><span style="color: #008000;"&gt;//</span><span style="color: #008000;"&gt; TODO Auto-generated method stub</span>
    System.out.println(Thread.currentThread().getName()+"开始执行了"<span style="color: #000000;"&gt;);
    </span><span style="color: #0000ff;"&gt;while</span><span style="color: #000000;"&gt;(flag) {

    }
    System.out.println(Thread.currentThread().getName()</span>+"执行完毕"<span style="color: #000000;"&gt;);
}

}

import java.io.IOException;

public class Demo3 {

</span><span style="color: #0000ff;"&gt;public</span> <span style="color: #0000ff;"&gt;static</span> <span style="color: #0000ff;"&gt;void</span> main(String[] args) <span style="color: #0000ff;"&gt;throws</span><span style="color: #000000;"&gt; IOException,InterruptedException {
    </span><span style="color: #008000;"&gt;//</span><span style="color: #008000;"&gt; TODO Auto-generated method stub</span>
    InterruptStop interruptStop=<span style="color: #0000ff;"&gt;new</span><span style="color: #000000;"&gt; InterruptStop();
    interruptStop.start();
    System.out.println(</span>"在10秒之内输入任意符号结束"<span style="color: #000000;"&gt;);
    System.in.read();
    interruptStop.interrupt();</span><span style="color: #008000;"&gt;//</span><span style="color: #008000;"&gt;打断正在休眠的线程</span>

interruptStop.join();
System.out.println("主线程结束...");
}
}
class InterruptStop extends Thread{
@Override
public void run() {
try {
Thread.sleep(10000);//抛出一个异常InterruptedException
} catch (InterruptedException e) {
// TODO Auto-generated catch block
// e.printStackTrace();
System.out.println("执行了catch");
}
System.out.println("子线程执行完毕");
}
}

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!