java中的多线程

Question

我希望“runnable”以 5tps 的速度运行。这不是并行执行。

package tt;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.DataInputStream;
import java.io.FileInputStream;
import java.io.FileWriter;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.URL;
import java.net.URLConnection;
import java.util.ArrayList;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
import java.util.logging.Level;
import java.util.logging.Logger;

public class mySpawner {

public int tillDone = 0;
public int tillMax = 0;
public ArrayList arrayList;
private myWorker myworking;
private ScheduledExecutorService service = Executors.newScheduledThreadPool(50);

Runnable runnable = new Runnable() {

    @Override
    public void run() {
        try {
            System.out.println(System.nanoTime());
            Thread.sleep(7000);
        } catch (InterruptedException ex) {
            Logger.getLogger(mySpawner.class.getName()).log(Level.SEVERE, null, ex);
        }
    }
};


public void activate() {
    try {
        service = Executors.newScheduledThreadPool(50);
        service.scheduleAtFixedRate(runnable, 0, 200, TimeUnit.MILLISECONDS);
    } catch (Exception e) {//Catch exception if any
        System.err.println("Error: " + e.getMessage());
    }

}

public void deactivate() {
    service.shutdown();
}

}

Answer 1

考虑一下：

• 您的任务在执行期间休眠了 7 秒
• 您每 200 毫秒调度一个新任务
• 您的执行器中只有 50 个线程

我希望您应该清楚，您将在短短几分钟内耗尽池中的线程几秒钟，你就会失去并行性。您需要通过降低频率或减少睡眠来更好地平衡这一点。增加池大小不会有帮助，您仍然会耗尽线程。

Answer 2

scheduleAtFixedRate 仅生成单个线程，但以固定速率执行提供的可运行对象。

• 该操作运行的时间少于给定的时间段：在这种情况下，它会在指定的时间段内重新生成。
• 该操作运行时间更长（您的情况）：该操作立即再次开始。

如果您想获得所需的行为，可以使用以下模式：只需执行一次可运行的：

service.schedule(runnable, 0, TimeUnit.MILLISECONDS);

但在可运行的 run 方法内添加下一个调用，

service.schedule(runnable, 200, TimeUnit.MILLISECONDS);

尽管如此，请考虑 skaffman 的答案中描述的算术。

Answer 3

更新：霍华德是对的，我的第一个例子是错误的。

我验证了如果您更改 active() 方法，此方法有效：

service = Executors.newScheduledThreadPool(50);
new Thread() {
    public void run() {
        long nextTime = System.currentTimeMillis();
        while (true) {
            service.submit(runnable);
            long waitTime = nextTime - System.currentTimeMillis();
            Thread.sleep(Math.max(0, waitTime));
            nextTime += 200;
        }
    }
}.start();