我有任务要做,我有点卡住了。我要做4个服务(A,B,C,D)。每个服务都应该有自己的线程。它们应该按顺序开始并运行。如果服务A启动,则可以启动服务B,如果服务B启动,如果服务C启动,则可以启动服务D。我设法创建了服务及其线程,但我不知道如何在PriorityService类中的start()和priority()方法之间创建通信。我想检查服务(线程)A是否活着,如果是,我想从列表移到第二个服务,等等。这可能吗?您还有其他关于如何编写服务依赖项的想法吗?任何建议都是有用的。TNX.
下面是我的代码:
import java.util.*;
class CreateThread extends Thread{
private String thread_name;
public int numb;
public CreateThread(String thread_name, int i){
this.thread_name=thread_name;
System.out.println("Thread " + thread_name + " has started.");
i=numb;
}
public void run(){
try{
Thread t = Thread.currentThread();
System.out.println(thread_name + " status = " + t.getState());
System.out.println(thread_name + " status = " + t.isAlive());
t.join();
}catch(Exception e){
System.out.println(e);
}
}
}
class PriorityService extends ArrayList<Service> {
public void priority()
{
int i=0;
while(i<size()){
System.out.println("evo me"+ get(i).service_name);
if(get(i).service_name=="Service A")
get(i).StartService(get(i).service_name, get(i).thread_name, i);
i++;
}
}
}
public class Service {
public String service_name;
public String thread_name;
public Service(String service_name, String thread_name){
this.service_name=service_name;
this.thread_name=thread_name;
}
public void StartService(String service_name, String thread_name, int i) {
System.out.println("Service " + service_name + " has started.");
Thread t=new Thread(new CreateThread(thread_name, i));
t.start();
}
public void StopService() {}
public static void main (String[] args){
PriorityService p_s=new PriorityService();
Service service_A = new Service("Service A", "Thread A");
Service service_B = new Service("Service B", "Thread B");
Service service_C = new Service("Service C", "Thread C");
Service service_D = new Service("Service D", "Thread D");
p_s.add(service_A);
p_s.add(service_B);
p_s.add(service_C);
p_s.add(service_D);
p_s.priority();
for(Service s: p_s)
System.out.println(s.service_name);
}
}
如果您为每个服务创建不同的线程,那么您就无法控制线程的执行(例如,通过设置其优先级等)。优先级只是操作系统的一个指标,但不能保证优先级较高的线程优先运行。
只有通过使用wait、notify、join等进行线程间通信才能做到这一点。
但我认为,如果你这样的话,解决方案可能是,为服务A、B、C&D的一个组合创建单独的线程。
主要内容:1 核心线程预启动,1.1 prestartCoreThread启动一条,1.2 prestartAllCoreThreads启动全部,2 关闭线程池,2.1 shutdown温和停止,2.2 shutdownNow立即停止,3 hook钩子方法,4 线程池信息获取,4.1 awaitTermination等待终止,4.2 getTaskCount计划任务数量,4.3 getActiveCount工作线程数量,,,,,,,,,,,前面的文章中,我们介绍了ThreadPoolExecut
考虑有两个线程正在等待执行同步块。现在有机会在这种情况下等待,我真的需要调用notify()吗?我认为当同步块执行完成时,其他线程会释放锁吗?notify()方法的确切用途是什么? 线程专家请解释?
本文向大家介绍Java中启动线程start和run的两种方法,包括了Java中启动线程start和run的两种方法的使用技巧和注意事项,需要的朋友参考一下 一、区别 Java中启动线程有两种方法,继承Thread类和实现Runnable接口,由于Java无法实现多重继承,所以一般通过实现Runnable接口来创建线程。但是无论哪种方法都可以通过start()和run()方法来启动线程,下面就来介绍
本文向大家介绍Java线程中start和run方法全面解析,包括了Java线程中start和run方法全面解析的使用技巧和注意事项,需要的朋友参考一下 自定义线程两种方法 自定义一个runnable接口的实现类,然后构造一个thread,即对thread传入一个runnable接口类。 new一个thread或者写个thread子类,覆盖它的run方法。(new 一个thread并覆盖run方法实
本文向大家介绍Java线程的start方法回调run方法的操作技巧,包括了Java线程的start方法回调run方法的操作技巧的使用技巧和注意事项,需要的朋友参考一下 面试中可能会被问到为什么我们调用start()方法时会执行run()方法,为什么我们不能直接调用run()方法? Java 创建线程的方法 实际上,创建线程最重要的是提供线程函数(回调函数),该函数作为新创建线程的入口函数,实现自己
脚本: 一群汽车从北向南(viceversa)沿着一条双车道道路行驶。过了一会儿,他们到达了一座桥。这座桥是单向的,通行能力有限。一辆汽车花100毫秒通过这座桥。不允许发生交通碰撞。 假设我需要计算,对于所有的车, 从车辆请求进入桥梁到开始穿越之间的时间。 例如:如果一辆向北行驶的汽车到达桥上,发现桥上有汽车向南行驶,它必须等待。它需要等多久?当然,如果只有一辆车(桥是空的),汽车的等待时间=0。