0532

/**
 * Created By WangLichao On 2016年12月26日.
 */
public class ListableFutureTest {
	private ExecutorService executor = Executors.newFixedThreadPool(1);  
    
    private ListeningExecutorService service = MoreExecutors.listeningDecorator(executor);  
      
    public static void main(String[] args){  
          

0532

/**
 * Created By WangLichao On 2016年12月7日.
 */
public class ThreadCheckProcess {

	private static final Logger beforeLoanlog = LoggerFactory.getLogger("beforeLoan");// 贷前
	private ExecutorService exec; // 线程池
	private int cpuNum; // 线程数
	private List<Future<Integer>> tasks = new ArrayList<Future<Integer>>(); // 接收线程处理的返回值
	

0532

package com.macrosky.dnd.controller.smails;

import java.util.Properties;
import java.util.ResourceBundle;

import javax.mail.BodyPart;
import javax.mail.Message;
import javax.mail.MessagingException;
import javax.mail.Multipart;
import javax.mail.Session;

0532

#!/bin/bash
#
###############################################
#author: 0532
#email: [email protected]
#date: 2016-06-16
###############################################
 
base_dir=$(cd "$(dirname "$0")";pwd)

0532

package io.terminus.neverest.notice.dao.site.caches;

import com.google.common.cache.Cache;
import com.google.common.cache.CacheBuilder;
import com.google.common.cache.CacheLoader;
import com.google.common.cache.LoadingCache;
import org.junit.Test;

import java.util.concurrent.Callable;

0532

package io.terminus.neverest.notice.dao.event;

import com.google.common.eventbus.AsyncEventBus;
import com.google.common.eventbus.EventBus;
import com.google.common.eventbus.Subscribe;

import java.util.concurrent.Executor;
import java.util.concurrent.Executors;

/**

0532

package liq.utils;

import java.io.File;
import java.util.Arrays;
import java.util.Enumeration;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Iterator;
import java.util.List;
import java.util.Map;

0532

package tmp;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.UnsupportedEncodingException;
import java.net.InetAddress;
import java.net.InetSocketAddress;
import java.net.Socket;

0532

package tmp;

import org.apache.commons.lang.StringUtils;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.client.HttpClient;
import org.apache.http.client.ResponseHandler;
import org.apache.http.client.methods.HttpGet;

0532

package apps.fis.ftp;

import org.apache.commons.lang.StringUtils;
import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPClientConfig;
import org.apache.commons.net.ftp.FTPFile;
import org.apache.commons.net.ftp.FTPReply;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;