Mercurial > hg > Database > Alice
view src/alice/test/codesegment/local/bitonicsort/OddPhase.java @ 200:099bb3afd74f working
no use managerKey
author | sugi |
---|---|
date | Sat, 23 Mar 2013 16:58:13 +0900 |
parents | caee170e6cfa |
children |
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(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(key1,index); info2 = ids.create(CommandType.TAKE); info2.setKey(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 = (DataList)info1.obj; if (count > sort_count){ ods.update("array"+info.range, list, false); return; } Sort.quickSort(list.table,0,list.table.size()-1); if (!info.lastFlag){ ods.put(info.range+"f", list.createDataList(0, block_num/2) ,false); ods.put(info.range+"b", list.createDataList(block_num/2, block_num/2) ,false); 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(info.range+"f",list, false); ods.put(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 = (DataList)info1.obj; DataList list2 = (DataList)info2.obj; DataList list3 = new DataList(); list3.table.addAll(list1.table); list3.table.addAll(list2.table); if (count > sort_count){ ods.update("array"+info.range, list3, false); return; } Sort.quickSort(list3.table,0,list3.table.size()-1); ods.put(info.range+"f", list3.createDataList(0, block_num/2) ,false); ods.put(info.range+"b", list3.createDataList(block_num/2, block_num/2) ,false); 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(info6.key, count+1); } }