继承Thread类
-
继承Thread类具备多线程能力
-
启动线程：子类对象 .start()
-
不建议使用：避免OOP单继承局限性
package demo;
//创建线程方式：继承Thread类，重写run方法，调用start方法开启线程
//线程开启不一定立即执行，由cpu调度
public class TestThread extends Thread{
@Override
public void run() {
//run方法线程体
for (int i = 0; i < 20; i++) {
System.out.println("kan"+i);
}
}
public static void main(String[] args) {
//main线程，主线程
//创建一个线程对象
TestThread testThread = new TestThread();
//调用start（）方法开始线程
testThread.start();
for (int i = 0; i < 200; i++) {
System.out.println("xue"+i);
}
}
}
创建方法二
实现Runnable接口
-
实现接口Runnable同样具有多线程能力
-
启动线程：传入目标对象+Thread对象.start()
-
推荐使用：可避免单继承局限性，灵活方便，方便同一个对象被多个线程使用
package demo;
//创建线程方法2：实现runnable接口，重写run方法，执行所需要丢入runnable接口实现类，调用start方法
public class TestRunnable implements Runnable{
@Override
public void run() {
for (int i = 0; i < 200; i++) {
System.out.println("kan"+i);
}
}
public static void main(String[] args) {
//创建runnable接口实现类对象
TestRunnable testRunnable = new TestRunnable();
//创建线程对象，通过线程对象来开启线程（代理）
new Thread(testRunnable).start();
for (int i = 0; i < 200; i++) {
System.out.println("xue"+i);
}
}
}
多个线程同时操作同一个对象（例如：购买火车票）
package demo;
//多个线程同时操作同一个对象
//买火车票
public class TestThread2 implements Runnable{
//票的总数
private int ticketNums=10;
@Override//重写run
public void run() {
while (true){
if (ticketNums<=0){//设置为==0会有意外惊喜
break;
}
//模拟延时
try {
Thread.sleep(200);
} catch (InterruptedException e) {
e.printStackTrace();
}
//输出新建代理的 name 与票的数量 票数自减
System.out.println(Thread.currentThread().getName()+"拿到了"+ticketNums--);
}
}
public static void main(String[] args) {
TestThread2 testThread2 = new TestThread2();
//新建代理
new Thread(testThread2,"name1").start();
new Thread(testThread2,"name2").start();
new Thread(testThread2,"name3").start();
//多个线程操作同一个资源的情况之下，线程不安全，数据紊乱。
}
}
龟兔赛跑（再次体验多线程）
package demo;
import com.sun.org.apache.bcel.internal.generic.NEW;
public class Race implements Runnable{
private static String winner=null;
@Override
public void run() {
for (int i = 0; i <= 200; i++) {
//判断比赛是否结束
boolean over =gameOver(i);
if (over){
break;
}
//模拟兔子睡觉
if (Thread.currentThread().getName().equals("兔子") && i==50){
try {
Thread.sleep(5);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
System.out.println(Thread.currentThread().getName()+"跑了"+i);
}
}
private boolean gameOver (int step){
//判断是否有胜利者
if (winner !=null){//胜利者已经存在
return true;
}if (step ==200){
winner =Thread.currentThread().getName();
System.out.println("winner is:"+winner);
return true;
}
return false;
}
public static void main(String[] args) {
Race race = new Race();
new Thread(race,"兔子").start();
new Thread(race,"乌龟").start();
}
}
创建方法三
实现callable接口 （以下载网图为例）
-
实现Callable接口，需要返回类型
-
重写call方法，需要抛出异常
-
创建目标对象
-
创建执行服务：ExecutorService ser= Executors.newFixedThreadPool(1);
-
提交执行：Future
result1=ser.submit(s1); -
获取结果：boolean rs1=result1.get();
-
关闭服务：ser.shutdownNow();
package demo; import org.apache.commons.io.FileUtils; import java.io.File; import java.io.IOException; import java.net.URL; import java.util.concurrent.*; public class TestThread3 implements Callable{ String url;//网图的地址 String name;//保存的文件名 //构造器传参 public TestThread3(String url,String name) { this.name=name; this.url=url; } @Override public Boolean call() { Downloader downloader = new Downloader(); downloader.downLoader(url,name); System.out.println("下载了文件名为："+name); return true; } public static void main(String[] args) throws ExecutionException, InterruptedException { //网图随便找，地址复制过来就行 TestThread3 c1 = new TestThread3("url1","name1"); TestThread3 c2 = new TestThread3("url1","name1"); TestThread3 c3 = new TestThread3("url1","name1"); //创建执行服务 ExecutorService ser= Executors.newFixedThreadPool(3); //提交执行 Future r1=ser.submit(c1); Future r2=ser.submit(c2); Future r3=ser.submit(c3); //获取结果 boolean rs1=r1.get(); boolean rs2=r1.get(); boolean rs3=r1.get();//会有异常抛出 //关闭服务 ser.shutdownNow(); } } //下载器 class Downloader{ public void downLoader(String url, String name){ //异常监听 try { //这里就是刚才导入的jar包中的其中一个方法 FileUtils.copyURLToFile(new URL(url),new File(name)); } catch (IOException e) { e.printStackTrace(); System.out.println("IO异常，downLoader方法出现问题"); } } }
静态代理（接口interface）
package lineProxy;
public class StacticProxy {
public static void main(String[] args) {
// User user = new User();
// UserServer userServer = new UserServer(user);
// userServer.proxy();
// 上三句代码效果等同与下一句代码
new UserServer(new User()).proxy();
}
}
interface Proxy{
void proxy();
}
//真实对象
class User implements Proxy{
@Override
public void proxy() {
System.out.println("这是代理");
}
}
//代理对象
class UserServer implements Proxy{
private Proxy target;
//构造器传参
public UserServer(Proxy target) {
this.target = target;
}
@Override
public void proxy() {
before();
target.proxy();//这是真实对象
after();
}
private void before(){
System.out.println("接受代理前");
}
private void after(){
System.out.println("接受代理后");
}
}
