java多线程

这个一个简单的java多线程应用普遍的实例。

package com.test.main;

import java.util.ArrayList;
import java.util.List;
import java.util.Vector;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

public class ThreadTest
{

    public static void main(String[] args)
    {
        Vector<User> vector = new Vector<User>();//保证线程安全
        for (int i = 0; i < 5; i++)
        {
            User user = new User();
            user.setUserName("zhangsan" + i);
            user.setPassword("123" + i);
            vector.add(user);
        }
       
        ThreadTest test = new ThreadTest();
        test.dealListWithMutiThread(vector);
    }

    public void dealListWithMutiThread(Vector<User> vector)
    {
        int index = 0;

        int threadCount=5;

        int size=vector.size();
        ExecutorService ex = Executors.newFixedThreadPool(threadCount);
        int dealSize = size%threadCount==0?size/threadCount:size/threadCount+1;
        List<Future<List<User>>> futures = new ArrayList<User>();
        // 分配
        for (int i = 0; i < 5; i++, index += dealSize)
        {
            int start = index;
            if (start >= vector.size())
                break;
            int end = start + dealSize;
            end = end > vector.size() ? vector.size() : end;//当处理的个数不够时候
            futures.add(ex.submit(new Task(vector, start, end)));
        }
        try
        {
            // 处理
            List<User> result = new ArrayList<User>();
            for (Future<List<User>> future : futures)
            {
                // 合并操作
                result.addAll(future.get());
            }
        }
        catch (Exception e)
        {
            e.printStackTrace();
        }
        finally
        {
            ex.shutdown();
        }
    }

    private class Task implements Callable<List<User>>
    {

        private Vector<User> vector;
        private int start;
        private int end;

        public Task(Vector<User> vector, int start, int end)
        {
            this.vector = vector;
            this.start = start;
            this.end = end;
        }

        @Override
        public List<User> call() throws Exception
        {
            User user = null;
            List<User> retList = new ArrayList<User>();
            for (int i = start; i < end; i++)
            {
                user = vector.get(i);
                System.err.println(Thread.currentThread().getName()
                        + " userName : " + user.getUserName());
            }
            return retList;
        }
    }
}