鸟瞰 Java 并发框架

10.1 示例代码

// 来自 controller : 
Actors.masterActor.tell(new Master.Request("Get Response", event, Actors.workerActor), ActorRef.noSender()); 
 
// handler : 
public Receive createReceive() { 
    return receiveBuilder().match(Request.class, request -> { 
    Event event = request.event; // Ideally, immutable data structures should be used here. 
    request.worker.tell(new JsonServiceWorker.Request("posts", event), getSelf()); 
    request.worker.tell(new JsonServiceWorker.Request("comments", event), getSelf()); 
    request.worker.tell(new JsonServiceWorker.Request("albums", event), getSelf()); 
    request.worker.tell(new JsonServiceWorker.Request("photos", event), getSelf()); 
    }).match(Event.class, e -> { 
    if (e.posts != null && e.comments != null & e.albums != null & e.photos != null) { 
    int userId = new Random().nextInt(10) + 1; 
    String postsAndCommentsOfRandomUser = ResponseUtil.getPostsAndCommentsOfRandomUser(userId, e.posts, 
    e.comments); 
    String albumsAndPhotosOfRandomUser = ResponseUtil.getAlbumsAndPhotosOfRandomUser(userId, e.albums, 
    e.photos); 
    String response = postsAndCommentsOfRandomUser + albumsAndPhotosOfRandomUser; 
    e.response = response; 
    e.countDownLatch.countDown(); 
    } 
    }).build(); 
} 

（编辑：南京站长网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!