Mercurial > hg > Database > Alice
view src/alice/test/codesegment/local/bitonicsort/OddPhase.java @ 166:a3f7f25f884b working
show data CS could change dynamic array
author | sugi |
---|---|
date | Fri, 14 Dec 2012 17:17:41 +0900 |
parents | 4fd7d0caf7e3 |
children | a8b0d44bbe68 |
line wrap: on
line source
package alice.test.codesegment.local.bitonicsort; import alice.codesegment.CodeSegment; import alice.datasegment.CommandType; import alice.datasegment.Receiver; public class OddPhase extends CodeSegment{ private Receiver info0 = ids.create(CommandType.PEEK); // range private Receiver info1; // Array1 private Receiver info2; // Array2 private Receiver info3 = ids.create(CommandType.PEEK); // block_num //private Receiver info4 = ids.create(CommandType.PEEK); // last_block_num private Receiver info5 = ids.create(CommandType.PEEK); // sort_count private Receiver info6 = ids.create(CommandType.TAKE); // count public OddPhase(String key0 ,String key1 ,int index,String key6){ info0.setKey(key0); info1 = ids.create(CommandType.TAKE); info1.setKey("local",key1,index); info3.setKey("block_num"); info5.setKey("sort_count"); info6.setKey(key6); } public OddPhase(String key0,String key1,String key2,int index,String key6){ info0.setKey(key0); info1 = ids.create(CommandType.TAKE); info1.setKey("local",key1,index); info2 = ids.create(CommandType.TAKE); info2.setKey("local",key2,index); info3.setKey("block_num"); info5.setKey("sort_count"); info6.setKey(key6); } @Override public void run() { RangeInfo info = info0.asClass(RangeInfo.class); int block_num = info3.asInteger(); int sort_count = info5.asInteger(); int count = info6.asInteger(); //System.out.println("count is " +count); if (info2==null){ DataList list = info1.asClass(DataList.class); if (count > sort_count){ ods.update("local", "array"+info.range, list); return; } Sort.quickSort(list.table,0,list.table.size()-1); if (!info.lastFlag){ ods.put("local", info.range+"f", list.createDataList(0, block_num/2)); ods.put("local", info.range+"b", list.createDataList(block_num/2, block_num/2)); if (info.range==0){ //System.out.println("next Even "+info.range+" "+info.range+"f"); new EvenPhase(info0.key,info.range+"f",count,info6.key); } else { //System.out.println("next Even "+info.range+" "+ (info.range-1)+"b"+" "+(info.range)+"f"); new EvenPhase(info0.key,(info.range-1)+"b",info.range+"f",count,info6.key); } } else { ods.put("local", info.range+"f",list); ods.put("local", info.range+"b","dummy"); //System.out.println("next Even "+info.range+" "+ (info.range-1)+"b"+" "+(info.range)+"f"); new EvenPhase(info0.key,(info.range-1)+"b",info.range+"f",count,info6.key); } } else { DataList list1 = info1.asClass(DataList.class); DataList list2 = info2.asClass(DataList.class); DataList list3 = new DataList(); list3.table.addAll(list1.table); list3.table.addAll(list2.table); if (count > sort_count){ ods.update("local", "array"+info.range, list3); return; } Sort.quickSort(list3.table,0,list3.table.size()-1); ods.put("local", info.range+"f", list3.createDataList(0, block_num/2)); ods.put("local", info.range+"b", list3.createDataList(block_num/2, block_num/2)); if (info.range==0){ //System.out.println("next Even2b "+info.range+" "+ info.range+"f"); new EvenPhase(info0.key,info.range+"f",count,info6.key); } else { //System.out.println("next Even2b "+info.range+" "+ (info.range-1)+"b"+" "+info.range+"f"); new EvenPhase(info0.key,(info.range-1)+"b",info.range+"f",count,info6.key); } } ods.update("local", info6.key, count+1); } }