public static void main(String[] args){ Runnable status_runnable=GenerateStatus();
Runnable session_runnable=MyThread(session);
Thread statusThread=Thread(status_runnable);//线程中放了任务
Thread session_thread=Thread(session_runnable);
statusThread.start();
session_thread.start();
}
两个类的实现如下,第一个是GenerateStatus
import java.util.Random;
public class GenerateStatus implements Runnable{
private String temperature;
private String free_Space;
public GenerateStatus(){
/*构造方法*/
}
/*线程中运行的程序*/
public void run() {//这里因为实现接口这个必须实现
Random random=new Random();
while(true)
{
temperature =((Integer)(random.nextInt(70)+20)).toString();
free_Space=((Integer)(random.nextInt(100)+1)).toString()+"G";
StatusMap.put("temperature",temperature);
StatusMap.put("free_Space",free_Space);
System.out.println("test");
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
第二个类MyThread
javax.websocket.Session;
java.io.IOException;
MyThread Runnable {
String ;
String ;
Session ;
MyThread(Session session) IOException {
.=session;
}
run() {
(){
{
Thread.();
} (InterruptedException e) {
e.printStackTrace();
}
System..println();
=StatusMap.();
=StatusMap.();
{
.getBasicRemote().sendText();
.getBasicRemote().sendText();
} (IOException e) {
e.printStackTrace();
}
}
}
}
PS:若只需一个线程,就可以直接建立个线程使其继承Thread,在主函数中直接调用。
Thread statusThread=new MyThread(session);
statusThread.start();//这样就可以了。但是不能多个线程同时运行!
亿速云「云服务器」,即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘,价格低至29元/月。点击查看>>
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。