静态变量实现线程之间的资源共享--以HelloCharts折线图为例

小王不头秃

发布于 2024-06-19 15:15:25

1050

发布于 2024-06-19 15:15:25

文章被收录于专栏：后端/图像融合/机器学习/爬虫后端/图像融合/机器学习/爬虫

静态变量实现线程之间的资源共享--以HelloCharts折线图为例

问题描述

这周进行的实训遇到一个问题，即有两个activity都需要获取服务器传来的数据并且进行显示，如下图两个activity(UI很丑)

这两个都需要获取服务器传来的数据，这两个页面获取的数据是相同的，如果按照以前的思维就是直接打开一个页面就建立一个socket连接然后获取数据，这样做有点慢，首先每次建立socket连接需要耗费资源，其次耗费时间也很多。

解决思路

我采用的是线程之间共享资源的方式，即当一个页面中接受数据的线程接受到数据之后，就通知另外一个页面接收数据的线程数据更新了，然后另一个页面的线程直接拿到数据。这个传递过程要使用一个静态标志位和一个静态信息对象来做数据的传递。

代码

获取数据的线程

//这边采用线程池（单例）的方式处理
 ThreadPool.single().execute(()->{

            try {
                while (state) {
                    final AllInfo info = ConnectUtil.singleConnectUtil().getAllInfo();
                    //将数据放在静态信息对象中
                    ConnectUtil.info=info;
                    //设置标志位为true，即通知另一个线程可以获取数据了
                    ConnectUtil.state=true;
                    //前端渲染
                    runOnUiThread(()->{
                        TextView p1text = findViewById( R.id.p1text);
                        TextView p2text = findViewById(R.id.p2text);
                        TextView p3text = findViewById(R.id.p3text);
                        TextView p4text = findViewById(R.id.p4text);
                        TextView p5text = findViewById(R.id.p5text);
                        TextView p6text = findViewById(R.id.p6text);
                        TextView p7text = findViewById(R.id.p7text);
                        TextView p8text = findViewById(R.id.p8text);
                        p1text.setText(info.getWendu() + "");
                        p2text.setText(info.getShidu() + "");
                        p3text.setText(info.getGuangzhao() + "");
                        p4text.setText(info.getDianchi() + "");
                        p5text.setText(info.getDianwei() + "");
                        p6text.setText(info.getX() + "");
                        p7text.setText(info.getY() + "");
                        p8text.setText(info.getZ() + "");
                    });
                    ThreadPool.single().execute(new Thread(){
                        @Override
                        public void run() {
                            AllService service=AllServiceImpl.single();
                            service.add(info);
                        }
                    });
                }

            } catch (final IOException e) {
                //由子线程切换至主线程
                runOnUiThread(new Runnable() {
                    @Override
                    public void run() {
                        Toast.makeText(getApplicationContext(), "网络有点慢" + e, Toast.LENGTH_SHORT).show();
                    }
                });
            }
        });

监听获取数据线程的另一个线程

thread=new Thread() {
            @Override
            public void run() {
                super.run();
                while (state) {
                //当检测到全局变量state改变之后就开始获取数据
                    if (ConnectUtil.state) {
                    //防止多次获取数据，将全局变量state赋值为false
                        ConnectUtil.state = false;
                        //获取全局变量信息存储数据
                        final AllInfo info = ConnectUtil.info;
                        }
                    }
    };
    //线程池的方式
        ThreadPool.single().execute(thread);