/* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License.
*/ package org.apache.tomcat.util.compat;
/** * This is the base implementation class for JRE compatibility and provides an * implementation based on Java 11. Sub-classes may extend this class and provide * alternative implementations for later JRE versions
*/ publicclass JreCompat {
/** * Return Unix domain socket address for given path. * @param path The path * @return the socket address
*/ public SocketAddress getUnixDomainSocketAddress(String path) { returnnull;
}
/** * Create server socket channel using the Unix domain socket ProtocolFamily. * @return the server socket channel
*/ public ServerSocketChannel openUnixDomainServerSocketChannel() { thrownew UnsupportedOperationException(sm.getString("jreCompat.noUnixDomainSocket"));
}
/** * Create socket channel using the Unix domain socket ProtocolFamily. * @return the socket channel
*/ public SocketChannel openUnixDomainSocketChannel() { thrownew UnsupportedOperationException(sm.getString("jreCompat.noUnixDomainSocket"));
}
// Java 11 implementations of Java 19 methods
/** * Obtains the executor, if any, used to create the provided thread. * * @param thread The thread to examine * * @return The executor, if any, that created the provided thread * * @throws NoSuchFieldException * If a field used via reflection to obtain the executor cannot * be found * @throws SecurityException * If a security exception occurs while trying to identify the * executor * @throws IllegalArgumentException * If the instance object does not match the class of the field * when obtaining a field value via reflection * @throws IllegalAccessException * If a field is not accessible due to access restrictions
*/ public Object getExecutor(Threadthread) throws NoSuchFieldException, SecurityException, IllegalArgumentException, IllegalAccessException {
Object result = null;
// Runnable wrapped by Thread // "target" in Sun/Oracle JDK // "runnable" in IBM JDK // "action" in Apache Harmony
Object target = null; for (String fieldName : new String[] { "target", "runnable", "action" }) { try {
Field targetField = thread.getClass().getDeclaredField(fieldName);
targetField.setAccessible(true);
target = targetField.get(thread); break;
} catch (NoSuchFieldException nfe) { continue;
}
}
// "java.util.concurrent" code is in public domain, // so all implementations are similar including our // internal fork. if (target != null && target.getClass().getCanonicalName() != null &&
(target.getClass().getCanonicalName().equals( "org.apache.tomcat.util.threads.ThreadPoolExecutor.Worker") ||
target.getClass().getCanonicalName().equals( "java.util.concurrent.ThreadPoolExecutor.Worker"))) {
Field executorField = target.getClass().getDeclaredField("this$0");
executorField.setAccessible(true);
result = executorField.get(target);
}
return result;
}
// Java 11 implementations of Java 21 methods
/** * Create a thread builder for virtual threads using the given name to name the threads. * * @param name The base name for the threads * * @return The thread buidler for virtual threads
*/ public Object createVirtualThreadBuilder(String name) { thrownew UnsupportedOperationException(sm.getString("jreCompat.noVirtualThreads"));
}
/** * Create a thread with the given thread builder and use it to execute the given runnable. * * @param threadBuilder The thread builder to use to create a thread * @param command The command to run
*/ publicvoid threadBuilderStart(Object threadBuilder, Runnable command) { thrownew UnsupportedOperationException(sm.getString("jreCompat.noVirtualThreads"));
}
}
¤ Dauer der Verarbeitung: 0.15 Sekunden
(vorverarbeitet)
¤
Die Informationen auf dieser Webseite wurden
nach bestem Wissen sorgfältig zusammengestellt. Es wird jedoch weder Vollständigkeit, noch Richtigkeit,
noch Qualität der bereit gestellten Informationen zugesichert.
Bemerkung:
Die farbliche Syntaxdarstellung ist noch experimentell.