Как основной поток передает информацию в дочерний поток (Как я могу обработать сообщение в методе выполнения？)? - PullRequest
Новая
       4

Как основной поток передает информацию в дочерний поток (Как я могу обработать сообщение в методе выполнения？)?

0 голосов
/ 21 октября 2018 
    public class MainActivity extends AppCompatActivity {

    public static final int TRANSMIT_DATA = 1;
    public static String string0;
    public String temp;//定义全局变量，想要把string0的值传给它。

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        loadData();
        System.out.println("Main output:ID="+Thread.currentThread().getId());
        anotherThread();
    }

    public void anotherThread(){
        new Thread(){
            public void run() {
                System.out.println("anotherThread :ID="+Thread.currentThread().getId());
                System.out.println("anotherThread output: Content="+temp);
            }
        }.start();  //开启一个线程
    }

    private Handler dataHandler =new Handler(){
        @Override
        public void handleMessage(Message msg) {
            switch (msg.what) {
                case TRANSMIT_DATA:
                    System.out.println("handleMessage output:ID="+Thread.currentThread().getId());
                    System.out.println("handleMessage output: Content="+msg.obj);

                    temp=msg.obj.toString();

                    break;
                default:
                    break;
            }
        }
    };


    public  void loadData() {


        OkHttpClient okHttpClient = new OkHttpClient();
        //构造Request,
        //builder.get()代表的是get请求，url方法里面放的参数是一个网络地址
        Request.Builder builder = new Request.Builder();

        final Map params = new LinkedHashMap();// 请求参数

        Request request = builder.get()
                .url("https://api.avatardata.cn/Jztk/Query?key=15f9ceafeeb94a2492fd84b8c68a554c&subject=4&model=c1&testType=rand")
                .build();
        //3将Request封装成call
        Call call = okHttpClient.newCall(request);

        //4，执行call，这个方法是异步请求数据
        call.enqueue(new Callback() {
            @Override
            public void onFailure(Call call, IOException e) {
                //失败调用
                Log.e("MainActivity", "onFailure: " );
            }

            @Override
            public void onResponse(Call call, final Response response) throws IOException {
                //成功调用
                Log.e("MainActivity", "onResponse: " );

                //获取网络访问返回的字符串
                string0 = response.body().string();

                System.out.println("Asynchronous Request Output:ID="+Thread.currentThread().getId());

                Message message = new Message();
                message.obj = string0;
                message.what =TRANSMIT_DATA;

                dataHandler.sendMessage(message);

            }
        });

    }

}

Изображение примерно соответствует System.out.println

Как показано на рисунке выше: "anotherThread output: Content = null", из которого я хочу передать информациюосновной поток к дочернему потоку (в методе run), как я могу это сделать?Старайтесь не менять код других методов как можно скорее.

Ответы [ 2 ]

0 голосов
/ 22 октября 2018

Я думаю, что ваша "другая нить" начинается и заканчивается до того, как данные становятся доступны в переменной temp, поэтому она выводит ноль.

Вы можете сделать что-то вроде:

a.Либо вы запускаете / запускаете свою «другую нить» после того, как вы заполнили переменную temp в функции handleMessage.

б.Или, если вы настаиваете на запуске «otherthread» до того, как у вас есть данные, синхронизируйте поток, проверьте переменную temp на ненулевое значение через некоторый интервал.Также есть что-то вроде логического типа, чтобы сообщить потоку, чтобы выйти, если вы не получили никаких данных.

мои 2 цента

0 голосов
/ 21 октября 2018

Учитывая, что вы хотите минимальных изменений кода, вы можете использовать ThreadLocal, значение, установленное в родительских потоках ThreadLocal, доступно для всех дочерних потоков

...