org.wikibrain.utils.WpThreadUtils类的使用及代码示例

x33g5p2x  于2022-02-03 转载在 其他  
字(5.6k)|赞(0)|评价(0)|浏览(104)

本文整理了Java中org.wikibrain.utils.WpThreadUtils类的一些代码示例，展示了WpThreadUtils类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。WpThreadUtils类的具体详情如下：
包路径：org.wikibrain.utils.WpThreadUtils
类名称：WpThreadUtils

WpThreadUtils介绍

暂无

代码示例

代码示例来源：origin: shilad/wikibrain

  1. private static int getMinimumReasonableConnections() {
  2.     return 2 * WpThreadUtils.getMaxThreads() + 12;
  3.   }
  4. }

代码示例来源：origin: shilad/wikibrain

  1. int maxThreads = configuration.get().getInt("maxThreads");
  2.   if (maxThreads > 0) {
  3.     WpThreadUtils.setMaxThreads(maxThreads);
  4. LOG.info("using max vm heapsize of " + (Runtime.getRuntime().maxMemory() / (1024*1024)) + "MB");
  5. LOG.info("using languages " + getLanguages());
  6. LOG.info("using maxThreads " + WpThreadUtils.getMaxThreads());
  7. LOG.info("using tmpDir " + tmpDir);

代码示例来源：origin: shilad/wikibrain

  1. public int getMaxThreads() {
  2.   return WpThreadUtils.getMaxThreads();
  3. }

代码示例来源：origin: org.wikibrainapi/wikibrain-utils

  1. public static <T> void loop(
  2.     Collection<T> collection,
  3.     final Procedure<T> fn,
  4.     final int logModulo) {
  5.   loop(collection, WpThreadUtils.getMaxThreads(), new Function<T, Object> () {
  6.     public Object call(T arg) throws Exception {
  7.       fn.call(arg);
  8.       return null;
  9.     }
  10.   }, logModulo);
  11. }
  12. public static <T,R> List<R> loop(

代码示例来源：origin: org.wikibrainapi/wikibrain-utils

  1. public static <T> void loop(
  2.     Collection<T> collection,
  3.     final Procedure<T> fn) {
  4.   loop(collection, WpThreadUtils.getMaxThreads(), fn, 50);
  5. }
  6. public static <T> void loop(

代码示例来源：origin: shilad/wikibrain

  1. public static <T> void loop(
  2.     Collection<T> collection,
  3.     final Procedure<T> fn,
  4.     final int logModulo) {
  5.   loop(collection, WpThreadUtils.getMaxThreads(), new Function<T, Object> () {
  6.     public Object call(T arg) throws Exception {
  7.       fn.call(arg);
  8.       return null;
  9.     }
  10.   }, logModulo);
  11. }
  12. public static <T,R> List<R> loop(

代码示例来源：origin: shilad/wikibrain

  1. public static <T> void loop(
  2.     Collection<T> collection,
  3.     final Procedure<T> fn) {
  4.   loop(collection, WpThreadUtils.getMaxThreads(), fn, 50);
  5. }
  6. public static <T> void loop(

代码示例来源：origin: org.wikibrainapi/wikibrain-utils

  1. public static <T> void iterate(Iterator<T> iterator, final Procedure<T> fn, int logModulo) {
  2.   iterate(iterator, WpThreadUtils.getMaxThreads(), 100, fn, logModulo);
  3. }

代码示例来源：origin: shilad/wikibrain

  1. public static <T,R> List<R> range(int from, int to, final Function<Integer, R> fn) {
  2.   return range(from, to, WpThreadUtils.getMaxThreads(), fn);
  3. }

代码示例来源：origin: org.wikibrainapi/wikibrain-utils

  1. public static <T,R> List<R> range(int from, int to, final Function<Integer, R> fn) {
  2.   return range(from, to, WpThreadUtils.getMaxThreads(), fn);
  3. }

代码示例来源：origin: shilad/wikibrain

  1. public static <T> void iterate(Iterator<T> iterator, final Procedure<T> fn, int logModulo) {
  2.   iterate(iterator, WpThreadUtils.getMaxThreads(), 100, fn, logModulo);
  3. }

代码示例来源：origin: org.wikibrainapi/wikibrain-loader

  1. private void createWorkers() {
  2.   workers.clear();
  3.   for (int i = 0; i < WpThreadUtils.getMaxThreads(); i++) {
  4.     Thread t = new Thread(new Worker());
  5.     t.start();
  6.     workers.add(t);
  7.   }
  8. }

代码示例来源：origin: shilad/wikibrain

  1. private void createWorkers() {
  2.   workers.clear();
  3.   for (int i = 0; i < WpThreadUtils.getMaxThreads(); i++) {
  4.     Thread t = new Thread(new Worker());
  5.     t.start();
  6.     workers.add(t);
  7.   }
  8. }

代码示例来源：origin: shilad/wikibrain

  1. public static synchronized void benchmark() {
  2.   long before = System.currentTimeMillis();
  3.   microBench();
  4.   long after = System.currentTimeMillis();
  5.   double secs = (after - before) / 1000.0;
  6.   singleCoreSpeed = 0.5 / secs;
  7.   int numThreads = WpThreadUtils.getMaxThreads();
  8.   before = System.currentTimeMillis();
  9.   ParallelForEach.range(0, numThreads, new Procedure<Integer>() {
  10.     @Override
  11.     public void call(Integer arg) throws Exception {
  12.       microBench();
  13.     }
  14.   });
  15.   after = System.currentTimeMillis();
  16.   secs = (after - before) / 1000.0 / WpThreadUtils.getMaxThreads();
  17.   multiCoreSpeed = 0.5 / secs;
  18. }

代码示例来源：origin: org.wikibrainapi/wikibrain-loader

  1. public static synchronized void benchmark() {
  2.   long before = System.currentTimeMillis();
  3.   microBench();
  4.   long after = System.currentTimeMillis();
  5.   double secs = (after - before) / 1000.0;
  6.   singleCoreSpeed = 0.5 / secs;
  7.   int numThreads = WpThreadUtils.getMaxThreads();
  8.   before = System.currentTimeMillis();
  9.   ParallelForEach.range(0, numThreads, new Procedure<Integer>() {
  10.     @Override
  11.     public void call(Integer arg) throws Exception {
  12.       microBench();
  13.     }
  14.   });
  15.   after = System.currentTimeMillis();
  16.   secs = (after - before) / 1000.0 / WpThreadUtils.getMaxThreads();
  17.   multiCoreSpeed = 0.5 / secs;
  18. }

代码示例来源：origin: org.wikibrainapi/wikibrain-utils

  1. public static <T,R> List<R> loop(
  2.     Collection<T> collection,
  3.     final Function<T,R> fn) {
  4.   return loop(collection, WpThreadUtils.getMaxThreads(), fn, 50);
  5. }
  6. public static <T> void loop(

代码示例来源：origin: shilad/wikibrain

  1. public static <T,R> List<R> loop(
  2.     Collection<T> collection,
  3.     final Function<T,R> fn) {
  4.   return loop(collection, WpThreadUtils.getMaxThreads(), fn, 50);
  5. }
  6. public static <T> void loop(

代码示例来源：origin: shilad/wikibrain

  1. public void load() throws DaoException {
  2.   totalLinks.set(0);
  3.   newLinks.set(0);
  4.   interestingLinks.set(0);
  5.   ParallelForEach.iterate(
  6.       new MySqlDumpParser().parse(sqlDump).iterator(),
  7.       WpThreadUtils.getMaxThreads(),
  8.       1000,
  9.       new Procedure<Object[]>() {
  10.         @Override
  11.         public void call(Object[] row) throws Exception {
  12.           processOneLink(row);
  13.         }
  14.       },
  15.       1000000
  16.   );
  17. }

代码示例来源：origin: shilad/wikibrain

  1. public static void range(int from, int to, final Procedure<Integer> fn) {
  2.   iterate(new IntRangeIterator(from, to), WpThreadUtils.getMaxThreads(), 10000, fn, Integer.MAX_VALUE);
  3. }
  4. public static <T,R> List<R> range(int from, int to, int numThreads, final Function<Integer, R> fn) {

代码示例来源：origin: org.wikibrainapi/wikibrain-utils

  1. public static void range(int from, int to, final Procedure<Integer> fn) {
  2.   iterate(new IntRangeIterator(from, to), WpThreadUtils.getMaxThreads(), 10000, fn, Integer.MAX_VALUE);
  3. }
  4. public static <T,R> List<R> range(int from, int to, int numThreads, final Function<Integer, R> fn) {

内容来源于网络，如有侵权，请联系作者删除！

WpThreadUtils

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    WpThreadUtils类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com