zoukankan      html  css  js  c++  java
  • 并行流水线--求 (B+C)*B/2

    public class Msg {
        public double i;
        public double j;
        public String orgStr = null;
    }
    
    import java.util.concurrent.BlockingQueue;
    import java.util.concurrent.LinkedBlockingQueue;
    
    /**
     * A = B + C
     * j = i + j
     */
    public class Plus implements Runnable {
        public static BlockingQueue<Msg> queue = new LinkedBlockingQueue<>();
    
        @Override
        public void run() {
            while (true){
                try {
                    Msg msg = queue.take();
                    msg.j=msg.i+msg.j;
                    Multiply.queue.add(msg);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
    }
    
    
    import java.util.concurrent.BlockingQueue;
    import java.util.concurrent.LinkedBlockingQueue;
    
    /**
     * D = A * B
     * i = i * (i+j)
     */
    public class Multiply implements Runnable{
        public static BlockingQueue<Msg> queue = new LinkedBlockingQueue<>();
    
        @Override
        public void run() {
            while (true){
                try {
                    Msg msg = queue.take();
                    msg.i=msg.i*msg.j;
                    Div.queue.add(msg);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
    }
    
    
    import java.util.concurrent.BlockingQueue;
    import java.util.concurrent.LinkedBlockingQueue;
    
    /**
     * D = D / 2
     * i =  i * (i+j)/2
     */
    public class Div implements Runnable {
        public static BlockingQueue<Msg> queue = new LinkedBlockingQueue<>();
        @Override
        public void run() {
            while (true){
                try {
                    Msg msg = queue.take();
                    msg.i=msg.i/2;
                    System.out.println(msg.orgStr+"="+msg.i);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
    }
    
    
    /**
     * 并行流水线
     * 求 (B+C)*B/2
     *      Plus:A = B + C
     *  Multiply:D = A * B
     *       Div:D = D / 2
     *
     *  i =  i * (i+j)/2
     */
    public class PStreamMain {
        public static void main(String[] args){
            new Thread(new Plus()).start();
            new Thread(new Multiply()).start();
            new Thread(new Div()).start();
            for (int B = 1; B < 1000; B++) {
                for (int C = 1; C < 1000; C++) {
                    Msg msg = new Msg();
                    msg.i = B;
                    msg.j = C;
                    msg.orgStr = "(("+B+"+"+C+")*"+B+")/2";
                    Plus.queue.add(msg);
                }
            }
        }
        //((1+1)*1)/2=1.0
        //((1+2)*1)/2=1.5
        //((1+3)*1)/2=2.0
        //((1+4)*1)/2=2.5
        //((1+5)*1)/2=3.0
        //((1+6)*1)/2=3.5
        //((1+7)*1)/2=4.0
        //((1+8)*1)/2=4.5
        //((1+9)*1)/2=5.0
        //((1+10)*1)/2=5.5
        //((1+11)*1)/2=6.0
        //((1+12)*1)/2=6.5
        //...
    }
    
  • 相关阅读:
    perl中的反勾号(``),system和exec
    经典的JavaScript效果
    关于Asp.net ajax下的异常处理
    史上最酷的IIS一键安装,你想要吗? 博客园全球首发
    下载最新的AjaxControlToolkit控件包
    Asp.net开发中不可靠的编码习惯
    用Ajax保持会话
    对ViewState的一点思考
    对微软Asp.net Ajax 1.0的AutoComplete控件的几处修正和增强
    还为安装IIS发愁吗?全系列IIS自动安装程序倾囊奉送!--技术原理介绍及成品下载
  • 原文地址:https://www.cnblogs.com/fly-book/p/11475843.html
Copyright © 2011-2022 走看看