ограничение времени выполнения образца потоков в Java - PullRequest
Новая
       15

ограничение времени выполнения образца потоков в Java

2 голосов
/ 03 февраля 2011

Я хочу имитировать планировщик в Java.У меня три темы определены.Теперь я хочу, чтобы поток 1 занимал 10% времени, поток 2 - 30%, а поток 3 - оставшиеся 60% времени.

Все три потока - задачи непрерывного мониторинга, которые никогда не завершатся.

т.е. если я выполняю программу в течение 100 минут, то поток 1 выполняется в течение 10 минут, поток 2 в течение 30 минут и поток 3 в течение 60 минут.

, а также при каждом перемещении потоков(т. е. другой поток переходит в состояние выполнения), я должен напечатать, что «Поток x выполнен за Y секунд»

Может ли кто-нибудь предоставить несколько указаний по достижению вышеупомянутого моделирования в Java.

1 Ответ

2 голосов
/ 03 февраля 2011

Эта ссылка должна быть интересной. 

import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
public class MainThread
{
        public static void main(String[] args)
        {
                int corePoolSize = 2;
                ScheduledThreadPoolExecutor stpe = new ScheduledThreadPoolExecutor(corePoolSize);

                /*
                 * This will execute the WorkerThread immediately
                 */
                stpe.execute(new WorkerThread("WorkerThread-Running-Immediately"));

                /*
                 * This will execute the WorkerThread only once after 10 Seconds
                 */
                stpe.schedule(new WorkerThread("WorkerThread-Scheduled-After-10-seconds"), 10, TimeUnit.SECONDS);

                /*
                 * This will execute the WorkerThread continuously for every 5 seconds with an initial delay of 10
                 * seconds for the first WorkerThread to start execution cycle. In this case, whether the first
                 * WorkerThread is completed or not, the second WorkerThread will start exactly after 5 seconds hence
                 * called schedule at fixed rate. This continues till 'n' threads are executed.
                 */
                stpe.scheduleAtFixedRate(new WorkerThread("WorkerThread-Running-At-Fixed-Rate"), 10, 5, TimeUnit.SECONDS);

                /*
                 * This will execute the WorkerThread continuously with an initial delay of 10 seconds for the first
                 * WorkerThread to start execution cycle. Once the first thread execution completes then a delay of 5
                 * Seconds is introduced so that the next WorkerThread execution cycle starts. This continues till
                 * 'n' thread are executed. This is called schedule each thread with a fixed delay.
                 */
                stpe.scheduleWithFixedDelay(new WorkerThread("WorkerThread-Running-With-Fixed-Delay"), 10, 5, TimeUnit.SECONDS);
        }
}

И рабочий поток: 

public class WorkerThread implements Runnable
{
        private String  threadName      = null;

        public WorkerThread(String threadName)
        {
                this.threadName = threadName;
        }

        public void run()
        {
                System.out.println(this.threadName + " started...");
                try
                {
                        Thread.sleep(5000);
                }
                catch (InterruptedException e)
                {
                        e.printStackTrace();
                }
                System.out.println(this.threadName + " ended...");
        }
}
...