|
Glassfish example source code file (EjbAsyncInvocationManager.java)
The Glassfish EjbAsyncInvocationManager.java source code/* * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER. * * Copyright (c) 1997-2010 Oracle and/or its affiliates. All rights reserved. * * The contents of this file are subject to the terms of either the GNU * General Public License Version 2 only ("GPL") or the Common Development * and Distribution License("CDDL") (collectively, the "License"). You * may not use this file except in compliance with the License. You can * obtain a copy of the License at * https://glassfish.dev.java.net/public/CDDL+GPL_1_1.html * or packager/legal/LICENSE.txt. See the License for the specific * language governing permissions and limitations under the License. * * When distributing the software, include this License Header Notice in each * file and include the License file at packager/legal/LICENSE.txt. * * GPL Classpath Exception: * Oracle designates this particular file as subject to the "Classpath" * exception as provided by Oracle in the GPL Version 2 section of the License * file that accompanied this code. * * Modifications: * If applicable, add the following below the License Header, with the fields * enclosed by brackets [] replaced by your own identifying information: * "Portions Copyright [year] [name of copyright owner]" * * Contributor(s): * If you wish your version of this file to be governed by only the CDDL or * only the GPL Version 2, indicate your decision by adding "[Contributor] * elects to include this software in this distribution under the [CDDL or GPL * Version 2] license." If you don't indicate a single choice of license, a * recipient has the option to distribute your version of this file under * either the CDDL, the GPL Version 2 or to extend the choice of license to * its licensees as provided above. However, if you add GPL Version 2 code * and therefore, elected the GPL Version 2 license, then the option applies * only if the new code is made subject to such option by the copyright * holder. */ package com.sun.ejb.containers; import com.sun.ejb.EjbInvocation; import java.util.*; import java.util.concurrent.*; import java.util.concurrent.atomic.AtomicLong; import java.util.concurrent.atomic.AtomicInteger; import org.jvnet.hk2.annotations.Service; import org.jvnet.hk2.annotations.Inject; import org.jvnet.hk2.component.PostConstruct; import org.glassfish.api.invocation.InvocationManager; import org.glassfish.api.invocation.ComponentInvocation; import java.util.logging.Level; import java.util.logging.Logger; import com.sun.ejb.Container; import com.sun.logging.LogDomains; import java.lang.reflect.Method; import javax.ejb.EJBException; /** * @author Mahesh Kannan */ @Service public class EjbAsyncInvocationManager extends ThreadPoolExecutor { private Logger _logger = LogDomains.getLogger(EjbAsyncInvocationManager.class, LogDomains.EJB_LOGGER); private AtomicLong invCounter = new AtomicLong(); // Map of Remote Future<> tasks. private ConcurrentHashMap<Long, EjbFutureTask> remoteTaskMap = new ConcurrentHashMap<Long, EjbFutureTask>(); public EjbAsyncInvocationManager() { //TODO get the paramters from ejb-container config super(16, 32, 60, TimeUnit.SECONDS, new LinkedBlockingQueue()); super.setThreadFactory(new EjbAsyncThreadFactory()); } public Future createLocalFuture(EjbInvocation inv) { return createFuture(inv); } public Future createRemoteFuture(EjbInvocation inv, Container container, GenericEJBHome ejbHome) { // Create future but only use the local task to register in the // remote task map. We'll be replacing the result value with a // remote future task. EjbFutureTask localFutureTask = (EjbFutureTask) createFuture(inv); EjbRemoteFutureTask returnFuture = new EjbRemoteFutureTask(inv.getInvId(), ejbHome); // If this is a future task for a remote invocation // and the method has Future<T> return type, add the // corresponding local task to the async map. // TODO Need to work on cleanup logic. Maybe we should store // this in a per-container data structure so cleanup is automatic // on container shutdown / undeployment. Otherwise, we need a way to easily // identify all tasks for a given container for cleanup. Method m = inv.getMethod(); if( !(m.getReturnType().equals(Void.TYPE))) { remoteTaskMap.put(inv.getInvId(), localFutureTask); } return returnFuture; } private Future createFuture(EjbInvocation inv) { // Always create a Local future task that is associated with the // invocation. EjbFutureTask futureTask = new EjbFutureTask(new EjbAsyncTask(), this); // Assign a unique id to this async task long invId = invCounter.incrementAndGet(); inv.setInvId(invId); inv.setEjbFutureTask(futureTask); if( _logger.isLoggable(Level.FINE) ) { _logger.log(Level.FINE, "Creating new async future task " + inv); } return futureTask; } public Future submit(EjbInvocation inv) { //We need to clone this invocation as submitting //so that the inv is *NOT* shared between the //current thread and the executor service thread EjbInvocation asyncInv = inv.clone(); inv.clearYetToSubmitStatus(); asyncInv.clearYetToSubmitStatus(); EjbFutureTask futureTask = asyncInv.getEjbFutureTask(); // EjbAsyncTask.initialize captures calling thread's // CallerPrincipal and sets it on the dispatch thread // before authorization. futureTask.getEjbAsyncTask().initialize(asyncInv); return super.submit(futureTask.getEjbAsyncTask()); } public void cleanupContainerTasks(Container container) { Set<Map.Entry Other Glassfish examples (source code examples)Here is a short list of links related to this Glassfish EjbAsyncInvocationManager.java source code file: |
... this post is sponsored by my books ... | |
#1 New Release! |
FP Best Seller |
Copyright 1998-2021 Alvin Alexander, alvinalexander.com
All Rights Reserved.
A percentage of advertising revenue from
pages under the /java/jwarehouse
URI on this website is
paid back to open source projects.