public class CreateDemo { public static final int MAX_TUAN = 5; public static final String getCurThreadName(){ return Thread.currentThread().getName(); }
static int threadNo = 1;
static class DemoThread extends Thread{
public DemoThread(){
super("DemoThread-" + threadNo++);
}
public void run() {
for (int i = 1; i <MAX_TUAN; i++){
System.out.println(getName() + ", 轮次：" + i);
}
System.out.println(getName() + " 运行结束. ");
}
}
public static void main(String[] args){
Thread thread = null;
for (int i = 0; i < 2; i++) {
thread = new DemoThread();
thread.start();
}
System.out.println(getCurThreadName() + " 运行结束. ");
}
需要 继承 Thread 类，创建一个新的线程类。
同时重写run() 方法， 将需要并发的业务代码编写在 run() 方法中
实现Runnable接口创建线程目标类
package org.example;
public class CreateDemo2 { public static final int MAX_TURN = 5;
static int threadNo = 1;
static class RunTarget implements Runnable{
@Override
public void run() {
for (int i = 0; i < MAX_TURN; i++) {
System.out.println(ThreadUtil.getCurThreadName() + ", 轮次:" + i);
}
System.out.println("运行结束");
}
}
public static void main(String[] args) {
Thread thread = null;
for (int i = 0; i < 2; i++) {
Runnable target = new RunTarget();
thread = new Thread(target, "RunnableThread" + threadNo++);
thread.start();
}
}
