1.自定义

package com.jgyang.com;

public class MySyncThreadTest {

public static void main(String[] args) throws Exception {

CustomRunnable cRunnacle = new CustomRunnable();

Thread thread = new Thread(cRunnacle,"子线程");

thread.start(); //子线程执行

System.out.println("主线程做自己的事情");

thread.join(); //等待子线程执行完毕，这里会阻塞

System.out.println("获取子线程返回结果："+cRunnacle.getData());

}

static final class CustomRunnable implements Runnable{

private String a = "";

public void run() {

try {

System.out.println(Thread.currentThread().getName()+":执行 start");

Thread.sleep(2000); //子线程停留2秒

System.out.println(Thread.currentThread().getName()+":执行 end");

} catch (InterruptedException e) {

e.printStackTrace();

}

a = "Hello world";

}

private String getData() {

return a;

}

}

}

返回结果为：

2.使用FutureTask+Callable

package com.jgyang.com;

import java.util.concurrent.Callable;

import java.util.concurrent.FutureTask;

public class MySyncThreadTest2 {

public static void main(String[] args) throws Exception {

CustomCallable cRunnacle = new CustomCallable();

FutureTaskfutureTask = new FutureTask(cRunnacle);

Thread thread = new Thread(futureTask,"子线程");

thread.start(); //子线程执行

System.out.println("主线程做自己的事情--start");

System.out.println("获取子线程返回结果："+futureTask.get());//获取返回结果是会阻塞

System.out.println("主线程做自己的事情--end");

}

static final class CustomCallable implements Callable{

public String call() throws Exception {

System.out.println(Thread.currentThread().getName()+":执行 start");

Thread.sleep(2000); //子线程停留2秒

System.out.println(Thread.currentThread().getName()+":执行 end");

return "Hello world";

}

}

}

返回结果为：