您好,登录后才能下订单哦!
这篇文章主要介绍“Java多线程Thread怎么创建”的相关知识,小编通过实际案例向大家展示操作过程,操作方法简单快捷,实用性强,希望这篇“Java多线程Thread怎么创建”文章能帮助大家解决问题。
示例:
Thread thread1 = new Thread(new MyThread(), "mythread"); class MyThread extends Thread(){ public void run(){ System.out.println("My First Thread'); } }
示例:
Thread thread2 = new Thread(new Runnable{}{ public void run(){ System.out.println("This is my thread."); } });
thead1.start()
try{ #休眠1000ms Thread.sleep(1000); }catch(InterruptedException e){ e.printStackTrace(); }
System.out.println(Thread.currentThread().getName() + ":"+ Thread.currentThread().getId);
千万不用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())的判断而无法终止线程。
线程等待:当前线程就处于等待状态,直到其他线程调用了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(); } }
输出结果:
高优先级的线程将会获得更多的CPU资源。一共分为10个优先级。
public final void setPriority(int newPriority)
源码分析:
public final void setPriority(int newPriority) { ThreadGroup 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
类似守护进程,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线程。
关于“Java多线程Thread怎么创建”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识,可以关注亿速云行业资讯频道,小编每天都会为大家更新不同的知识点。
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。