文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

Java中怎么实现Thread队列

2023-06-17 16:04

关注

今天就跟大家聊聊有关Java中怎么实现Thread队列,可能很多人都不太了解,为了让大家更加了解,小编给大家总结了以下内容,希望大家根据这篇文章可以有所收获。

Java Thread队列一直是我们需要掌握的代码。下面我们就基本思想:建立了一个队列,为每一个Java Thread队列保存了一个对象锁,保证按顺序执行。线程启动的时候,使随机的,但是执行代码是按顺序的。

import java.util.LinkedList;  import java.util.Queue;  public class ThreadTest {  private static Queue qThread=new LinkedList();//线程同步对象队列  public static synchronized void putObject(Object t){  qThread.offer(t);  }  public static synchronized Object getObject(){  return qThread.poll();  }  public static void waitThread(Object t) throws InterruptedException{  synchronized(t){  t.wait();  }  }  public static void notifyThread(){  Object obj=ThreadTest.getObject();  synchronized(obj){  obj.notify();  }  }  public static void main(String[] args) throws InterruptedException {  int i = 0;  boolean isFirst=true;  while (i < 10) {  Object obj=new Object();  if(i>0){  isFirst=false;  ThreadTest.putObject(obj);  }  Thread t2 = new Thread2(isFirst,obj);  Object obj2=new Object();  ThreadTest.putObject(obj2);  Thread t3 = new Thread3(obj2);  t2.start();  t3.start();  i++;  }  }  }    class Thread2 extends Thread {  private boolean isFirst=false;  private Object obj;  public Thread2(boolean f,Object obj){  this.isFirst=f;  this.obj=obj;  }  @Override  public void run() {  if(!this.isFirst){  System.out.println(this.getName()+"等待...");  try{  ThreadTest.waitThread(obj);  }catch(InterruptedException e){  e.printStackTrace();  }  }  System.out.println("启动"+this.getName()+"...");  try {  sleep(3000);//等待3秒,为了测试  } catch (InterruptedException e) {  e.printStackTrace();  }  System.out.println("停止"+this.getName()+"...");  ThreadTest.notifyThread();  }  }  class Thread3 extends Thread {  private Object obj;  public Thread3(Object obj){  this.obj=obj;  }  @Override  public void run() {  System.out.println(this.getName()+"等待...");  try{  ThreadTest.waitThread(obj);  }catch(InterruptedException e){  e.printStackTrace();  }  System.out.println("启动"+this.getName()+"...");  try {  sleep(3000);//等待3秒,为了测试  } catch (InterruptedException e) {  e.printStackTrace();  }  System.out.println("停止"+this.getName()+"...");  ThreadTest.notifyThread();  }  }

看完上述内容,你们对Java中怎么实现Thread队列有进一步的了解吗?如果还想了解更多知识或者相关内容,请关注编程网行业资讯频道,感谢大家的支持。

阅读原文内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     807人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     351人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     314人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     433人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     221人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯