内部类问题

package concurrentMap;

import java.util.HashMap;
import java.util.concurrent.ConcurrentHashMap;

public class ConcurrencyHashMapTest {

	public ConcurrentHashMap<Integer, HashMap<Integer, Integer>> pMsgs = new ConcurrentHashMap<Integer, HashMap<Integer, Integer>>();

	public ConcurrencyHashMapTest() {
		
	}
	
	/**
	 * @param args
	 */
	public static void main(String[] args) {
		ConcurrencyHashMapTest chmt = new ConcurrencyHashMapTest() ;
		Thread t1 = new Thread(new Sender(chmt.pMsgs,1)) ;  //内部类问题报错, No enclosing instance of type ConcurrencyHashMapTest is accessible. Must qualify the allocation with an enclosing instance of type ConcurrencyHashMapTest (e.g. x.new A() where x is an instance of ConcurrencyHashMapTest).

		Thread t2 = new Thread(new Sender(chmt.pMsgs,2)) ;
		Thread t3 = new Thread(new Sender(chmt.pMsgs,2)) ;

		t1.start() ;
		t2.start() ;
		t3.start() ;
	}

	class Sender implements Runnable {
		ConcurrentHashMap<Integer, HashMap<Integer, Integer>> pMsgs;
		int id = -1  ;
		
		public Sender(ConcurrentHashMap<Integer, HashMap<Integer, Integer>> pMsgs, int partition) {
			this.pMsgs = pMsgs;
			id = partition ;
		}

		@Override
		public void run() {
			HashMap<Integer, Integer> partition = new HashMap<Integer, Integer>();
			for (int i = 0; i < 10000; i++)
				partition.put(i, 200);

			pMsgs.put(id, partition);
		}
	}
}

</pre><pre code_snippet_id="1688919" snippet_file_name="blog_20160519_1_9021163" name="code" class="java">修改后<pre name="code" class="java">package concurrentMap;

import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.RandomAccessFile;
import java.util.HashMap;
import java.util.Map;
import java.util.Random;
import java.util.concurrent.ConcurrentHashMap;

public class ConcurrencyHashMapTest {

	public ConcurrentHashMap<Integer, HashMap<Integer, Integer>> pMsgs = new ConcurrentHashMap<Integer, HashMap<Integer, Integer>>();

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		ConcurrencyHashMapTest chmt = new ConcurrencyHashMapTest() ;
		<span style="color:#ff0000;">Thread t1 = new Thread(chmt.new Sender(chmt.pMsgs,1)) ; //内部类必须先定义外部类实例后才能定义!
		Thread t2 = new Thread(chmt.new Sender(chmt.pMsgs,2)) ;
		Thread t3 = new Thread(chmt.new Sender(chmt.pMsgs,2)) ;</span>

		t1.start() ;
		t2.start() ;
		t3.start() ;
		
		try {
			RandomAccessFile raf = new RandomAccessFile("F:\\test\\Concurrency.txt", "rw") ;
			Thread.currentThread().sleep(1000) ;
			for(Map.Entry<Integer, HashMap<Integer, Integer>> partition : chmt.pMsgs.entrySet()){
				System.out.println("Partition " + partition.getKey() + " Size:  " +  partition.getValue().size() +"\n") ;
				raf.writeBytes(partition.toString()) ;
			}
			raf.close() ;
		} catch (InterruptedException e) {
			e.printStackTrace();
		} catch (FileNotFoundException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		}
	}

	class Sender implements Runnable {
		ConcurrentHashMap<Integer, HashMap<Integer, Integer>> pMsgs;
		int part = -1  ;
		
		public Sender(ConcurrentHashMap<Integer, HashMap<Integer, Integer>> pMsgs, int partition) {
			this.pMsgs = pMsgs;
			this.part = partition ;
		}

		@Override
		public void run() {
			HashMap<Integer, Integer> partition = new HashMap<Integer, Integer>();
			int id = (int) Thread.currentThread().getId() ;
			for (int i = 0; i < 10000; i++)
				partition.put(i, id);

			pMsgs.put(part, partition);
			System.out.println("Thread " + id + " Partition " + part + " is inserted! ");

		}
	}
}