blocks|key|2229554|text|为什么不让类实现Runnable接口并传递这些实例，而不是传递每个类的名称并使用反射？(请记住将接收方部分中的类称为Runnable，而不是使用类名)。|type|unstyled|depth|inlineStyleRanges|offset|length|style|BOLD|entityRanges|data|2229555|__UPDATE__|2229556|public+interface+Schedulable+extends+Runnable{
+++//In+case+you+need+extra+API.+If+not,+you+don't+
++//need+this+interface,+just+use+Runnable+instead.
}


public+class+ScheduleAtFixedRate+implements+Schedulable{
+++++public+void+run(){
+++++++++//+run+at+fixed+rate
+++++}
}


public+class+ScheduleAtVariableRate+implements+Schedulable{
+++++public+void+run(){
+++++++++//+run+at+fixed+rate
+++++}
}

public+class+ScheduledExecutorService{
++++...

++++public+void+execute(Schedulable+s){
+++++++++new+Thread(s).start();
++++}
++++...

}|code-block|syntax|javascript|2229557|entityMap^0|18|U|0|0|A|0|0^^$0|@$1|2|3|4|5|6|7|O|8|@$9|P|A|Q|B|C]]|D|@]|E|$]]|$1|F|3|G|5|6|7|R|8|@$9|S|A|T|B|C]]|D|@]|E|$]]|$1|H|3|I|5|J|7|U|8|@]|D|@]|E|$K|L]]|$1|M|3|-4|5|6|7|V|8|@]|D|@]|E|$]]]|N|$]]

Why don't you make your classes implement Runnable interface and pass those instances instead of passing the name of each class and use Reflection ? ( Please remember to refer to your classes in the receiver part as Runnable, not with your class names )

__UPDATE__

<pre><code>public interface Schedulable extends Runnable{
 //In case you need extra API. If not, you don't 
 //need this interface, just use Runnable instead.
}


public class ScheduleAtFixedRate implements Schedulable{
 public void run(){
 // run at fixed rate
 }
}


public class ScheduleAtVariableRate implements Schedulable{
 public void run(){
 // run at fixed rate
 }
}

public class ScheduledExecutorService{
 ...

 public void execute(Schedulable s){
 new Thread(s).start();
 }
 ...

}
</code></pre>

blocks|key|2283630|text|假设您有两个类|type|unstyled|depth|inlineStyleRanges|entityRanges|data|2283631|public+class+ABC++extends+TimerTask{+
@Override
public+void+run()
{/*some+code*/}


public+class+XYZ+extends+TimerTask{
@Override
public+void+run()
{/*some+code*/}
}|code-block|syntax|javascript|2283632|然后从某个班级|2283633|public+class+ScheduleTheTask{

public+static+void+main(String[]+args)+{
begin("com.ABC",new+Date(),3000);
begin("com.XYZ",new+Date(),3000);
}

+++public+static+void+begin(String+task+,+Date+startTime,long+timeInMillisecons)


+++++{
++++++++++++++++Class<?>+clazz+=+Class.forName(task);
//BIG+assumption+that+only+TimerTask++subclasses+would+be+passed+add+a+instanceof+check
++++++++++++++++TimerTask+taskObj=+(TimerTask)clazz.newInstance();
++++++++++++++++setStartTimeAndInterval();
++++++++++++++++Timer+timer+=+new+Timer();
++++++++++++++++timer.scheduleAtFixedRate(taskObj,+startTime,timeInMillisecons);

++++++++++++}
}|2283634|entityMap^0|0|0|0|0^^$0|@$1|2|3|4|5|6|7|M|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|N|8|@]|9|@]|A|$E|F]]|$1|G|3|H|5|6|7|O|8|@]|9|@]|A|$]]|$1|I|3|J|5|D|7|P|8|@]|9|@]|A|$E|F]]|$1|K|3|-4|5|6|7|Q|8|@]|9|@]|A|$]]]|L|$]]

Assume you have two classes 

<pre><code>public class ABC extends TimerTask{ 
@Override
public void run()
{/*some code*/}


public class XYZ extends TimerTask{
@Override
public void run()
{/*some code*/}
}
</code></pre>

And then from some class 

<pre><code>public class ScheduleTheTask{

public static void main(String[] args) {
begin("com.ABC",new Date(),3000);
begin("com.XYZ",new Date(),3000);
}

 public static void begin(String task , Date startTime,long timeInMillisecons)


 {
 Class&lt;?&gt; clazz = Class.forName(task);
//BIG assumption that only TimerTask subclasses would be passed add a instanceof check
 TimerTask taskObj= (TimerTask)clazz.newInstance();
 setStartTimeAndInterval();
 Timer timer = new Timer();
 timer.scheduleAtFixedRate(taskObj, startTime,timeInMillisecons);

 }
}
</code></pre>

blocks|key|2229626|text|您可以使用与工作线程一样的task_key+(某些字符串)作为键和值的映射，即Runnable|type|unstyled|depth|inlineStyleRanges|offset|length|style|CODE|entityRanges|data|2229627|下面就是这样的一个例子|2229628|package+com.test.thread;

import+java.util.Date;
import+java.util.HashMap;
import+java.util.Map;
import+java.util.concurrent.Executors;
import+java.util.concurrent.ScheduledExecutorService;
import+java.util.concurrent.TimeUnit;

public+class+ScheduleTask+{

++++private+ScheduledExecutorService+scheduledThreadPool+=+Executors.newScheduledThreadPool(5);

++++public+void+schedule(String+task)+throws+InterruptedException+{
++++++++System.out.println("Current+Time+=+"%2Bnew+Date());
++++++++scheduledThreadPool.scheduleAtFixedRate(getTasks().get(task),+0,+10,+TimeUnit.SECONDS);

++++++++Thread.sleep(30000);
++++}

++++public+void+waitForTaskToComplete()+{
++++++++scheduledThreadPool.shutdown();
++++++++while(!scheduledThreadPool.isTerminated()){
++++++++++++//wait+for+all+tasks+to+finish
++++++++}
++++++++System.out.println("Finished+all+threads");
++++}

++++public+Map<String,+Runnable>+getTasks()+{
++++++++Map<String,+Runnable>+tasks+=+new+HashMap<String,+Runnable>();
++++++++tasks.put("task1",+new+WorkerThread("task1"));
++++++++tasks.put("task2",+new+WorkerThread("task2"));
++++++++return+tasks;
++++}

++++public+static+void+main(String[]+args)+throws+InterruptedException+{
++++++++ScheduleTask+scheduleTask+=+new+ScheduleTask();
++++++++scheduleTask.schedule("task1");
++++++++scheduleTask.schedule("task2");

++++}
}|code-block|syntax|javascript|2229629|entityMap^0|13|8|0|0|0^^$0|@$1|2|3|4|5|6|7|O|8|@$9|P|A|Q|B|C]]|D|@]|E|$]]|$1|F|3|G|5|6|7|R|8|@]|D|@]|E|$]]|$1|H|3|I|5|J|7|S|8|@]|D|@]|E|$K|L]]|$1|M|3|-4|5|6|7|T|8|@]|D|@]|E|$]]]|N|$]]

You can use a map with some task_key (some string) as key and value as your worker thread i.e. <code>Runnable</code> 

Below is one such example

<pre><code>package com.test.thread;

import java.util.Date;
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;

public class ScheduleTask {

 private ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(5);

 public void schedule(String task) throws InterruptedException {
 System.out.println("Current Time = "+new Date());
 scheduledThreadPool.scheduleAtFixedRate(getTasks().get(task), 0, 10, TimeUnit.SECONDS);

 Thread.sleep(30000);
 }

 public void waitForTaskToComplete() {
 scheduledThreadPool.shutdown();
 while(!scheduledThreadPool.isTerminated()){
 //wait for all tasks to finish
 }
 System.out.println("Finished all threads");
 }

 public Map&lt;String, Runnable&gt; getTasks() {
 Map&lt;String, Runnable&gt; tasks = new HashMap&lt;String, Runnable&gt;();
 tasks.put("task1", new WorkerThread("task1"));
 tasks.put("task2", new WorkerThread("task2"));
 return tasks;
 }

 public static void main(String[] args) throws InterruptedException {
 ScheduleTask scheduleTask = new ScheduleTask();
 scheduleTask.schedule("task1");
 scheduleTask.schedule("task2");

 }
}
</code></pre>

I am trying to write a scheduler class that can schedule different classes set on some user specified timer. I am using

<pre><code>ScheduledExecutorService
</code></pre>

and 

<pre><code>ScheduleAtFixedRate
</code></pre>

to do the scheduling. What I am struggling with is how to tell the scheduler which Java class to schedule.

The idea is that you'd call the scheduler and in the constructor would be some string, which would be the name of the java class you want to schedule. I have issues using said String in 

<pre><code>ScheduleAtFixedRate
</code></pre>

because it requires a runnable. Any thoughts or advice?

How to schedule different java classes dynamically?

翻译质量差，导致语言生硬或混乱。

没有提供实际的解决方法或示例。

解答不清晰，无法理解或解决问题。

页面排版不美观，阅读体验差。

文章

问答

视频

学习中心

腾讯云实验室

直播

竞赛

腾讯云代码分析专区

腾讯iOA零信任安全管理系统专区

腾讯云架构师技术同盟交流圈

腾讯云数据库专区

腾讯云顾问专区

腾讯云原生专区

腾讯混元专区

腾讯云TCE专区

腾讯云Lighthouse专区

腾讯云HAI专区

腾讯云Edgeone专区

腾讯云存储专区

腾讯云智能专区

腾讯轻联专区 

腾讯云开发专区

TAPD专区

腾讯轻量云游戏服专区

腾讯云最具价值专家

腾讯云架构师技术同盟

腾讯云创作之星

腾讯云开发者先锋

腾讯云代码助手

云原生构建

TAPD 敏捷项目管理

Cloud Studio

SDK中心

API中心

命令行工具

涵盖代码开发、场景应用、自动测试全流程，助你从零构建专属AI助手

一站式MCP教程库，解锁AI应用新玩法

我正在尝试编写一个调度程序类，它可以在某个用户指定的计时器上调度不同的类。我在用ScheduledExecutorService和ScheduleAtFixedRate去做日程安排。我正在苦苦挣扎的是如何告诉调度程序要调度哪个Java类。这样做的想法是调用调度程序，构造函数中将有一些字符串，这将是您想要调度的java类...

问如何动态调度不同的java类？
EN

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问如何动态调度不同的java类？EN