java代码如何实现异步 java异步函数

提示：扫一扫查出行
【扫一扫了解最新限行尾号】
复制提示

java 异步调用方法

1. 使用wait和notify方法

这个方法其实是利用了锁机制java代码如何实现异步，直接贴代码:

public class Demo1 extends BaseDemo{ private final Object lock = new Object(); @Override public void callback(long response) { System.out.println("得到结果"); System.out.println(response); System.out.println("调用结束"); synchronized (lock) { lock.notifyAll(); } } public static void main(String[] args) { Demo1 demo1 = new Demo1(); demo1.call(); synchronized (demo1.lock){ try { demo1.lock.wait(); } catch (InterruptedException e) { e.printStackTrace(); } } System.out.println("主线程内容"); } }

可以看到在发起调用后java代码如何实现异步，主线程利用wait进行阻塞，等待回调中调用notify或者notifyAll方法来进行唤醒。注意，和大家认知的一样，这里wait和notify都是需要先获得对象的锁的。在主线程中最后我们打印了一个内容，这也是用来验证实验结果的，如果没有wait和notify，主线程内容会紧随调用内容立刻打印;而像我们上面的代码，主线程内容会一直等待回调函数调用结束才会进行打印。

没有使用同步操作的情况下，打印结果:发起调用调用返回主线程内容得到结果 1 调用结束

而使用了同步操作后:

发起调用调用返回得到结果 9 调用结束主线程内容2. 使用条件锁

和方法一的原理类似:

public class Demo2 extends BaseDemo { private final Lock lock = new ReentrantLock(); private final Condition con = lock.newCondition(); @Override public void callback(long response) { System.out.println("得到结果"); System.out.println(response); System.out.println("调用结束"); lock.lock(); try { con.signal(); }finally { lock.unlock(); } } public static void main(String[] args) { Demo2 demo2 = new Demo2(); demo2.call(); demo2.lock.lock(); try { demo2.con.await(); } catch (InterruptedException e) { e.printStackTrace(); }finally { demo2.lock.unlock(); } System.out.println("主线程内容"); } }

基本上和方法一没什么区别，只是这里使用了条件锁，两者的锁机制有所不同。

相关问答

Q1: Java多线程实现异步调用

在JAVA平台实现异步调用java代码如何实现异步的角色有如下三个角色:调用者提货单真实数据一个调用者在调用耗时操作不能立即返回数据时先返回一个提货单然后在过一断时间后凭提货单来获取真正java代码如何实现异步的数据去蛋糕店买蛋糕不需要等蛋糕做出来（假设现做要很长时间）只需要领个提货单就可以java代码如何实现异步了（去干别的事情）等到蛋糕做好java代码如何实现异步了再拿提货单取蛋糕就可以java代码如何实现异步了 public class Main { public static void main(String[] args) {

System out println( main BEGIN );

Host host = new Host();

Data data = host request( A );

Data data = host request( B );

Data data = host request( C );

System out println( main otherJob BEGIN );

try {

Thread sleep( );

} catch (InterruptedException e) {

}

System out println( main otherJob END );

System out println( data = + data getContent());

System out println( main END );

}

这里的main类就相当于顾客 host就相当于蛋糕店顾客向蛋糕店定蛋糕就相当于发请求request 返回的数据data是FutureData的实例就相当于提货单而不是真正的蛋糕在过一段时间后（sleep一段时间后）调用data getContent() 也就是拿提货单获取执行结果

下面来看一下顾客定蛋糕后蛋糕店做了什么

public class Host {

public Data request(final int count final char c) {

System out println( request( + count + + c + ) BEGIN );

// ( ) 建立FutureData的实体

final FutureData future = new FutureData();

// ( ) 为了建立RealData的实体启动新的线程

new Thread() {

public void run() {

//在匿名内部类中使用count future c

RealData realdata = new RealData(count c);

future setRealData(realdata);

}

} start();

System out println( request( + count + + c + ) END );

// ( ) 取回FutureData实体作为传回值

return future;

}

host( 蛋糕店 )在接到请求后先生成了提货单 FutureData的实例future 然后命令蛋糕师傅 RealData去做蛋糕 realdata相当于起个线程去做蛋糕了然后host返回给顾客的仅仅是提货单 future 而不是蛋糕当蛋糕做好后蛋糕师傅才能给对应的提货单蛋糕也就是future setRealData(realdata)

下面来看看蛋糕师傅是怎么做蛋糕的

建立一个字符串包含count个c字符为了表现出犯法需要花费一些时间使用了sleep

public class RealData implements Data { private final String content;

public RealData(int count char c) {

System out println( making RealData( + count + + c + ) BEGIN );

char[] buffer = new char[count];

for (int i = ; i count; i++) {

buffer[i] = c;

try {

Thread sleep( );

} catch (InterruptedException e) {

}

System out println( making RealData( + count + + c + ) END );

ntent = new String(buffer);

}

public String getContent() {

return content;

}

现在来看看提货单 future是怎么与蛋糕 content 对应的:

public class FutureData implements Data { private RealData realdata = null;

private boolean ready = false;

public synchronized void setRealData(RealData realdata) {

if (ready) {

return; // 防止setRealData被调用两次以上

}

this realdata = realdata;

this ready = true;

notifyAll();

}

public synchronized String getContent() {

while (!ready) {

try {

wait();

} catch (InterruptedException e) {

}

return realdata getContent();

}

顾客做完自己的事情后会拿着自己的提货单来取蛋糕

System out println( data = + data getContent());

这时候如果蛋糕没做好就只好等了

while (!ready) { try {

wait();

} catch (InterruptedException e) {

}

//等做好后才能取到

return realdata getContent();

程序分析

对于每个请求 host都会生成一个线程这个线程负责生成顾客需要的蛋糕在等待一段时间以后如果蛋糕还没有做好顾客还必须等待直到蛋糕被做好也就是

future setRealData(realdata); 执行以后顾客才能拿走蛋糕

每个线程只是专门负责制作特定顾客所需要的蛋糕也就是顾客A对应着蛋糕师傅A 顾客B对应着蛋糕师傅B 即使顾客B的蛋糕被先做好了顾客A也只能等待蛋糕师傅A把蛋糕做好换句话说顾客之间没有竞争关系

lishixinzhi/Article/program/Java/gj/201311/27425

Q2: 如何用JAVA实现异步信息处理

通常同步意味着一个任务的某个处理过程会对多个线程在用串行化处理，而异步则意味着某个处理过程可以允许多个线程同时处理。异步通常代表着更好的性能，因为它很大程度上依赖于缓冲，是典型的使用空间换时间的做法，例如在计算机当中，高速缓存作为cpu和磁盘io之间的缓冲地带协调cpu高速计算能力和磁盘的低速读写能力。

（1）：重新启动一个java程序就启动了一个进程

可以用操作系统命令行启动 Runtime.getRuntime().exec("java -classpath . XXX");

（2）：可不可以在接收消息的模块中的addtolist函数中添加一个专门的处理函数，函数执行时先向list中添加消息，然后探测当前有没有处理线程，如果没有，则启动线程。

（3）：想省点工作，可以用BlockingQueue来代替list，这样线程等待和唤醒不用写代码实现了，如果非要用list，那么就做好同步

list的小例子：

Java codeclass MessageConsumer extends Thead { private ListYourMessageType list; private boolean running = true; public MessageConsumer(ListYourMessageType list) {this.list = list;} public void run() { while (running) { YourMessageType msg = null; try { synchronized(list) { while (list.size() == 0) { list.wait(); } msg = list.remove(0); list.notiryAll(); } } catch (Exception e) { e.printStackTrace(); } if (msg == null) continue; //System.out.println(msg); //print message } }}//调用sampleclass ShareModule { ListYourMessageType list = new ArrayListYourMessageType(); ...}public class Main { public static void main(String[] args) { ShareMudule sm; //so on ... Thread t = new MessageConsumer(sm.list); t.start(); ... }}

关于java代码如何实现异步和java异步函数的介绍到此就结束了，不知道你从中找到你需要的信息了吗？如果你还想了解更多这方面的信息，记得收藏关注本站。