|
Java example source code file (AsynchronousChannelProvider.java)
The AsynchronousChannelProvider.java Java example source code/* * Copyright (c) 2007, 2013, Oracle and/or its affiliates. All rights reserved. * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. * * This code is free software; you can redistribute it and/or modify it * under the terms of the GNU General Public License version 2 only, as * published by the Free Software Foundation. Oracle designates this * particular file as subject to the "Classpath" exception as provided * by Oracle in the LICENSE file that accompanied this code. * * This code is distributed in the hope that it will be useful, but WITHOUT * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License * version 2 for more details (a copy is included in the LICENSE file that * accompanied this code). * * You should have received a copy of the GNU General Public License version * 2 along with this work; if not, write to the Free Software Foundation, * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA. * * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA * or visit www.oracle.com if you need additional information or have any * questions. */ package java.nio.channels.spi; import java.nio.channels.*; import java.io.IOException; import java.util.Iterator; import java.util.ServiceLoader; import java.util.ServiceConfigurationError; import java.util.concurrent.*; import java.security.AccessController; import java.security.PrivilegedAction; /** * Service-provider class for asynchronous channels. * * <p> An asynchronous channel provider is a concrete subclass of this class that * has a zero-argument constructor and implements the abstract methods specified * below. A given invocation of the Java virtual machine maintains a single * system-wide default provider instance, which is returned by the {@link * #provider() provider} method. The first invocation of that method will locate * the default provider as specified below. * * <p> All of the methods in this class are safe for use by multiple concurrent * threads. </p> * * @since 1.7 */ public abstract class AsynchronousChannelProvider { private static Void checkPermission() { SecurityManager sm = System.getSecurityManager(); if (sm != null) sm.checkPermission(new RuntimePermission("asynchronousChannelProvider")); return null; } private AsynchronousChannelProvider(Void ignore) { } /** * Initializes a new instance of this class. * * @throws SecurityException * If a security manager has been installed and it denies * {@link RuntimePermission}<tt>("asynchronousChannelProvider") */ protected AsynchronousChannelProvider() { this(checkPermission()); } // lazy initialization of default provider private static class ProviderHolder { static final AsynchronousChannelProvider provider = load(); private static AsynchronousChannelProvider load() { return AccessController .doPrivileged(new PrivilegedAction<AsynchronousChannelProvider>() { public AsynchronousChannelProvider run() { AsynchronousChannelProvider p; p = loadProviderFromProperty(); if (p != null) return p; p = loadProviderAsService(); if (p != null) return p; return sun.nio.ch.DefaultAsynchronousChannelProvider.create(); }}); } private static AsynchronousChannelProvider loadProviderFromProperty() { String cn = System.getProperty("java.nio.channels.spi.AsynchronousChannelProvider"); if (cn == null) return null; try { Class<?> c = Class.forName(cn, true, ClassLoader.getSystemClassLoader()); return (AsynchronousChannelProvider)c.newInstance(); } catch (ClassNotFoundException x) { throw new ServiceConfigurationError(null, x); } catch (IllegalAccessException x) { throw new ServiceConfigurationError(null, x); } catch (InstantiationException x) { throw new ServiceConfigurationError(null, x); } catch (SecurityException x) { throw new ServiceConfigurationError(null, x); } } private static AsynchronousChannelProvider loadProviderAsService() { ServiceLoader<AsynchronousChannelProvider> sl = ServiceLoader.load(AsynchronousChannelProvider.class, ClassLoader.getSystemClassLoader()); Iterator<AsynchronousChannelProvider> i = sl.iterator(); for (;;) { try { return (i.hasNext()) ? i.next() : null; } catch (ServiceConfigurationError sce) { if (sce.getCause() instanceof SecurityException) { // Ignore the security exception, try the next provider continue; } throw sce; } } } } /** * Returns the system-wide default asynchronous channel provider for this * invocation of the Java virtual machine. * * <p> The first invocation of this method locates the default provider * object as follows: </p> * * <ol> * * <li> Other Java examples (source code examples)Here is a short list of links related to this Java AsynchronousChannelProvider.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.