debop

    public static <T, V> List<V> run(final Iterable<T> elements, final Function1<T, V> function) {
        shouldNotBeNull(elements, "elements");
        shouldNotBeNull(function, "function");

        ExecutorService executor = Executors.newFixedThreadPool(getProcessCount());

        if (log.isDebugEnabled())
            log.debug("작업을 병렬로 수행합니다. 작업 스레드 수=[{}]", getProcessCount());

        try {

debop

@Slf4j
public class ParallelsTest {

    private static final int LowerBound = 0;
    private static final int UpperBound = 99999;

    @Test
    public void parallelRunAction() {
        final Action1<Integer> action1 =
                new Action1<Integer>() {

debop

package kr.kth.timeperiod

import org.joda.time.DateTimeConstants

/**
 * 한 주의 요일을 표현합니다.
 * User: sunghyouk.bae@gmail.com
 * Date: 13. 1. 13.
 */
object ScalaDayOfWeek extends Enumeration {

debop

package kr.kth.timeperiod

import kr.kth.commons.slf4j.Logging
import org.junit.{Assert, Test}
import org.joda.time.DateTimeConstants

/**
 * kr.kth.timeperiod.ScalaDayOfWeekTest
 * User: sunghyouk.bae@gmail.com
 * Date: 13. 1. 13.

debop

public static <T> T createInstance(Class<T> clazz) {

    Guard.shouldNotBeNull(clazz, "clazz");
    if (log.isDebugEnabled())
        log.debug("수형 [{}] 의 새로운 인스턴스를 생성합니다...", clazz.getName());

    try {
        return (T) clazz.newInstance();
    } catch (Exception e) {
        if (log.isWarnEnabled())

debop

/**
 * 지정된 수형의 새로운 인스턴스를 생성합니다.
 *
 * @param clazz 생성할 수형
 * @param <T>   수형
 * @return 지정한 수형의 새로운 인스턴스, 생성 실패시에는 null을 반환합니다.
 */
public static <T> T createInstance(Class<T> clazz) {

    Guard.shouldNotBeNull(clazz, "clazz");

debop

/**
 * Generic 수형의 클래스에 대해 기본 생성자를 통한 인스턴스를 생성합니다.
 */
def newInstance[T: ClassTag](): T = {
    classTag[T].runtimeClass.newInstance().asInstanceOf[T]
}

debop

/**
 * Generic 수형의 클래스에 대해 지정된 생성자 인자에 해당하는 생성자를 통해 인스턴스를 생성합니다.
 */
def newInstance[T: ClassTag](initArgs: Any*): T = {
    if (initArgs == null || initArgs.length == 0)
        return newInstance[T]()

    val parameterTypes = initArgs.map(getClass(_)).toArray
    val constructor = classTag[T].runtimeClass.getConstructor(parameterTypes: _*)
    constructor.newInstance(initArgs.map(_.asInstanceOf[AnyRef]): _*).asInstanceOf[T]

debop

def asJavaClass(x: Any): Class[_] = x match {

    case x: scala.Boolean => java.lang.Boolean.TYPE
    case x: scala.Char => java.lang.Character.TYPE
    case x: scala.Byte => java.lang.Byte.TYPE
    case x: scala.Short => java.lang.Short.TYPE
    case x: scala.Int => java.lang.Integer.TYPE
    case x: scala.Long => java.lang.Long.TYPE
    case x: scala.Float => java.lang.Float.TYPE
    case x: scala.Double => java.lang.Double.TYPE

debop

def newInstanceWithTypes[T: ClassTag](initArgs: Any*)(initArgsTypes: Class[_]*): T = {
    if (initArgs == null || initArgs.length == 0)
        return newInstance[T]()

    val parameterTypes =
        if (initArgsTypes != null) initArgsTypes.toArray
        else initArgs.map(asJavaClass(_)).toArray

    val constructor = classTag[T].runtimeClass.getConstructor(parameterTypes: _*)
    constructor.newInstance(initArgs.map(_.asInstanceOf[AnyRef]): _*).asInstanceOf[T]