4632N/A/*
4632N/A * Copyright (c) 2011, Oracle and/or its affiliates. All rights reserved.
4632N/A * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
4632N/A *
4632N/A * This code is free software; you can redistribute it and/or modify it
4632N/A * under the terms of the GNU General Public License version 2 only, as
4632N/A * published by the Free Software Foundation. Oracle designates this
4632N/A * particular file as subject to the "Classpath" exception as provided
4632N/A * by Oracle in the LICENSE file that accompanied this code.
4632N/A *
4632N/A * This code is distributed in the hope that it will be useful, but WITHOUT
4632N/A * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
4632N/A * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
4632N/A * version 2 for more details (a copy is included in the LICENSE file that
4632N/A * accompanied this code).
4632N/A *
4632N/A * You should have received a copy of the GNU General Public License version
4632N/A * 2 along with this work; if not, write to the Free Software Foundation,
4632N/A * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
4632N/A *
4632N/A * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
4632N/A * or visit www.oracle.com if you need additional information or have any
4632N/A * questions.
4632N/A */
4632N/A
4632N/A#import "com_apple_concurrent_LibDispatchNative.h"
4632N/A
4632N/A#import <dispatch/dispatch.h>
4632N/A#import <JavaNativeFoundation/JavaNativeFoundation.h>
4632N/A
4632N/A
4632N/A/*
4632N/A * Class: com_apple_concurrent_LibDispatchNative
4632N/A * Method: nativeIsDispatchSupported
4632N/A * Signature: ()Z
4632N/A */
4632N/AJNIEXPORT jboolean JNICALL Java_com_apple_concurrent_LibDispatchNative_nativeIsDispatchSupported
4632N/A(JNIEnv *env, jclass clazz)
4632N/A{
4632N/A return JNI_TRUE;
4632N/A}
4632N/A
4632N/A
4632N/A/*
4632N/A * Class: com_apple_concurrent_LibDispatchNative
4632N/A * Method: nativeGetMainQueue
4632N/A * Signature: ()J
4632N/A */
4632N/AJNIEXPORT jlong JNICALL Java_com_apple_concurrent_LibDispatchNative_nativeGetMainQueue
4632N/A(JNIEnv *env, jclass clazz)
4632N/A{
4632N/A dispatch_queue_t queue = dispatch_get_main_queue();
4632N/A return ptr_to_jlong(queue);
4632N/A}
4632N/A
4632N/A
4632N/A/*
4632N/A * Class: com_apple_concurrent_LibDispatchNative
4632N/A * Method: nativeCreateConcurrentQueue
4632N/A * Signature: (I)J
4632N/A */
4632N/AJNIEXPORT jlong JNICALL Java_com_apple_concurrent_LibDispatchNative_nativeCreateConcurrentQueue
4632N/A(JNIEnv *env, jclass clazz, jint priority)
4632N/A{
4632N/A dispatch_queue_t queue = dispatch_get_global_queue((long)priority, 0);
4632N/A return ptr_to_jlong(queue);
4632N/A}
4632N/A
4632N/A
4632N/A/*
4632N/A * Class: com_apple_concurrent_LibDispatchNative
4632N/A * Method: nativeCreateSerialQueue
4632N/A * Signature: (Ljava/lang/String;)J
4632N/A */
4632N/AJNIEXPORT jlong JNICALL Java_com_apple_concurrent_LibDispatchNative_nativeCreateSerialQueue
4632N/A(JNIEnv *env, jclass clazz, jstring name)
4632N/A{
4632N/A if (name == NULL) return 0L;
4632N/A
4632N/A jboolean isCopy;
4632N/A const char *queue_name = (*env)->GetStringUTFChars(env, name, &isCopy);
4632N/A dispatch_queue_t queue = dispatch_queue_create(queue_name, NULL);
4632N/A (*env)->ReleaseStringUTFChars(env, name, queue_name);
4632N/A
4632N/A return ptr_to_jlong(queue);
4632N/A}
4632N/A
4632N/A
4632N/A/*
4632N/A * Class: com_apple_concurrent_LibDispatchNative
4632N/A * Method: nativeReleaseQueue
4632N/A * Signature: (J)V
4632N/A */
4632N/AJNIEXPORT void JNICALL Java_com_apple_concurrent_LibDispatchNative_nativeReleaseQueue
4632N/A(JNIEnv *env, jclass clazz, jlong nativeQueue)
4632N/A{
4632N/A if (nativeQueue == 0L) return;
4632N/A dispatch_release((dispatch_queue_t)jlong_to_ptr(nativeQueue));
4632N/A}
4632N/A
4632N/A
4632N/Astatic JNF_CLASS_CACHE(jc_Runnable, "java/lang/Runnable");
4632N/Astatic JNF_MEMBER_CACHE(jm_run, jc_Runnable, "run", "()V");
4632N/A
4632N/Astatic void perform_dispatch(JNIEnv *env, jlong nativeQueue, jobject runnable, void (*dispatch_fxn)(dispatch_queue_t, dispatch_block_t))
4632N/A{
4632N/AJNF_COCOA_ENTER(env);
4632N/A dispatch_queue_t queue = (dispatch_queue_t)jlong_to_ptr(nativeQueue);
4632N/A if (queue == NULL) return; // shouldn't happen
4632N/A
4632N/A // create a global-ref around the Runnable, so it can be safely passed to the dispatch thread
4632N/A JNFJObjectWrapper *wrappedRunnable = [[JNFJObjectWrapper alloc] initWithJObject:runnable withEnv:env];
4632N/A
4632N/A dispatch_fxn(queue, ^{
4632N/A // attach the dispatch thread to the JVM if necessary, and get an env
4632N/A JNFThreadContext ctx = JNFThreadDetachOnThreadDeath | JNFThreadSetSystemClassLoaderOnAttach | JNFThreadAttachAsDaemon;
4632N/A JNIEnv *blockEnv = JNFObtainEnv(&ctx);
4632N/A
4632N/A JNF_COCOA_ENTER(blockEnv);
4632N/A
4632N/A // call the user's runnable
4632N/A JNFCallObjectMethod(blockEnv, [wrappedRunnable jObject], jm_run);
4632N/A
4632N/A // explicitly clear object while we have an env (it's cheaper that way)
4632N/A [wrappedRunnable setJObject:NULL withEnv:blockEnv];
4632N/A
4632N/A JNF_COCOA_EXIT(blockEnv);
4632N/A
4632N/A // let the env go, but leave the thread attached as a daemon
4632N/A JNFReleaseEnv(blockEnv, &ctx);
4632N/A });
4632N/A
4632N/A // release this thread's interest in the Runnable, the block
4632N/A // will have retained the it's own interest above
4632N/A [wrappedRunnable release];
4632N/A
4632N/AJNF_COCOA_EXIT(env);
4632N/A}
4632N/A
4632N/A
4632N/A/*
4632N/A * Class: com_apple_concurrent_LibDispatchNative
4632N/A * Method: nativeExecuteAsync
4632N/A * Signature: (JLjava/lang/Runnable;)V
4632N/A */
4632N/AJNIEXPORT void JNICALL Java_com_apple_concurrent_LibDispatchNative_nativeExecuteAsync
4632N/A(JNIEnv *env, jclass clazz, jlong nativeQueue, jobject runnable)
4632N/A{
4632N/A // enqueues and returns
4632N/A perform_dispatch(env, nativeQueue, runnable, dispatch_async);
4632N/A}
4632N/A
4632N/A
4632N/A/*
4632N/A * Class: com_apple_concurrent_LibDispatchNative
4632N/A * Method: nativeExecuteSync
4632N/A * Signature: (JLjava/lang/Runnable;)V
4632N/A */
4632N/AJNIEXPORT void JNICALL Java_com_apple_concurrent_LibDispatchNative_nativeExecuteSync
4632N/A(JNIEnv *env, jclass clazz, jlong nativeQueue, jobject runnable)
4632N/A{
4632N/A // blocks until the Runnable completes
4632N/A perform_dispatch(env, nativeQueue, runnable, dispatch_sync);
4632N/A}