返回

Java多线程基础学习(一)

发布时间:2022-11-02 03:02:47 313
# java# java

1. 创建线程   

1.1 通过构造函数:public Thread(Runnable target, String name){}  或:public Thread(Runnable target){}

示例:

Thread thread1 = new Thread(new MyThread(), "mythread");
class MyThread extends Thread(){
public void run(){
System.out.println("My First Thread');
}
}

1.2 直接实现Runnable接口:

示例:

Thread thread2 = new Thread(new Runnable{}{
public void run(){
System.out.println("This is my thread.");
}
});

2. 运行线程   

thead1.start()    

3. sleep

try{

#休眠1000ms

Thread.sleep(1000);

}catch(InterruptedException e){

e.printStackTrace();

}

4. getName() 获取线程名字, getId()获取线程id

System.out.println(Thread.currentThread().getName() + ":"+ Thread.currentThread().getId);

5. 停止线程,

千万不用stop(),stop会立即终止线程。

通过interrupt()中断线程,但是中断并没有停止线程,配合异常来实现:

public class Main {
public static void main(String[] args) throws InterruptedException {
try{
Thread thread1=new Thread(new TheThread(),"thread1");
thread1.start();
Thread.sleep(2000);
thread1.interrupt();
}catch (InterruptedException e){
e.printStackTrace();
}
}
}
class TheThread extends Thread{
public void run() {
super.run();
for (int i = 0; i < 10; i++) {
if(this.interrupted()){
break;
}
System.out.println(Thread.currentThread().getName() + ":" + i);
}
}
}

注意,如果在TheThread类里加入catch InterruptException的话,可能会导致interrupt被捕获,而绕过if(this.interrupted())的判断而无法终止线程。

6. 等待和通知        

线程等待:当前线程就处于等待状态,直到其他线程调用了notify()方法,线程才会继续执行

public final void wait() throws InterruptedException

线程通知:

public final native void notify()

注意:在notify()方法后,当前线程不会马上释放该对象锁,要等到执行notify()方法的线程将程序执行完,也就是退出同步代码块中。

package wait.notify;

public class ThreadWaitNotifyTest {

final static Object object=new Object();

public static class T1 extends Thread{

public void run(){

System.out.println(System.currentTimeMillis()+": T1 start");

synchronized (object){

try {

System.out.println(System.currentTimeMillis()+": T1 wait");

object.wait();

} catch (InterruptedException e) {

e.printStackTrace();

}

}

System.out.println(System.currentTimeMillis()+": T1 end");

}

}

public static class T2 extends Thread{

public void run(){

System.out.println(System.currentTimeMillis()+": T2 start");

synchronized (object){

System.out.println("T2 synchonized code start.");

object.notify();

try {

Thread.sleep(2000);

} catch (InterruptedException e) {

e.printStackTrace();

}finally{

System.out.println("T2 synchonized code end.");

}

}

try {

Thread.sleep(2000);

} catch (InterruptedException e) {

e.printStackTrace();

}

System.out.println(System.currentTimeMillis()+": T2 end");

}

}

public static void main(String[] args){

Thread thread1=new T1();

Thread thread2=new T2();

thread1.start();

thread2.start();

}

}

输出结果:

Java多线程基础学习(一)_守护线程

7. 线程优先级

高优先级的线程将会获得更多的CPU资源。一共分为10个优先级。

public final void setPriority(int newPriority)

源码分析:

public final void setPriority(int newPriority) {

ThreadvGroup g;

checkAccess();

if (newPriority > MAX_PRIORITY || newPriority < MIN_PRIORITY) {

throw new IllegalArgumentException();

}

if((g = getThreadGroup()) != null) {

if (newPriority > g.getMaxPriority()) {

newPriority = g.getMaxPriority();

}

setPriority0(priority = newPriority);

}

}
public final static int MIN_PRIORITY = 1;

public final static int NORM_PRIORITY = 5;

public final static int MAX_PRIORITY = 10;

可见线程最高优先级为10, 最低为1, 默认为5.

当设定的newPriority高于该线程组ThreadGroup的最高Priority时,只能分配该线程组的最高Priority

 

8. 守护线程

类似守护进程,Java存在两种线程:用户线程和守护线程。它是一种特殊线程,执行的是一种后台服务,当一个系统中不存在非守护线程的时候,守护线程会自己销毁。典型的守护线程:JVM的垃圾回收线程。

public final void setDaemon(boolean on)

示例:

public class Main {

public static void main(String[] args) throws InterruptedException {

TheThread theThread=new TheThread();

theThread.setDaemon(true);//设置守护线程

theThread.start();

Thread.sleep(5000);

System.out.println("全都退出啦");

}

public static class TheThread extends Thread{

public void run(){

int i = 0;

while (true){

i++;

System.out.println(Thread.currentThread().getId()+":"+i);

try {

Thread.sleep(2000);

} catch (InterruptedException e) {

e.printStackTrace();

}

}

}

}

}

源码分析:

设置线程为用户线程(user thread)或守护线程(daemon thread),当剩余运行的线程均为守护线程时,JVM会退出。

public final void setDaemon(boolean on) {

checkAccess();

if (isAlive()) {

throw new IllegalThreadStateException();

}

daemon = on;

}

其中checkAccesss()方法如下:

public final void checkAccess() {

SecurityManager security = System.getSecurityManager();

if (security != null) {

security.checkAccess(this);

}

}

该方法用于判断当前运行的线程是否有修改此线程的权限。

而public final native boolean isAlive();用于判断该线程是否处于alive状态,即该线程是否已经start,且没有die。

当isAlive的话就会抛出IllegalThreadStateException异常。

所以,设置守护线程的方法,逻辑就是先判断当前线程是否有修改的权限,再判断是否处于alive状态,如果不处于alive状态,则根据boolean变量on的值更改它的状态,即true:设为daemon线程,false:设为user线程。

特别声明:以上内容(图片及文字)均为互联网收集或者用户上传发布,本站仅提供信息存储服务!如有侵权或有涉及法律问题请联系我们。
举报
评论区(0)
按点赞数排序
用户头像
精选文章
thumb 中国研究员首次曝光美国国安局顶级后门—“方程式组织”
thumb 俄乌线上战争,网络攻击弥漫着数字硝烟
thumb 从网络安全角度了解俄罗斯入侵乌克兰的相关事件时间线
下一篇
java 01背包 清晰源代码 eclipse idea 2022-11-02 02:31:34