180 lines
5.3 KiB
C++
180 lines
5.3 KiB
C++
#ifndef THREE_PASS_XB_H
|
|
#define THREE_PASS_XB_H
|
|
/* Basically like threepass.h but but fewer bits - only for thiersort3! */
|
|
|
|
/* How the 28-30 bits gets separated? This is chosen because I saw that: */
|
|
/* - in float trickery I saw at around 4 billion the buckets change around 200 million */
|
|
/* - Which is smaller than 1/2 or 1/4 or 1/8 or 1/16 of it because 16*200 mil = 3.2 bill 28 bit is needed */
|
|
/* - This means those bits in numbers DO get used when we are running as internal sort of thier3 */
|
|
/* - But the numbers high bits (29..32th bits) stay the same inside each bucket so we spare it! */
|
|
/* - If you know your data does not have all the range of 32 bits you can #define these by #define CUSTOM_TPBX_BITS */
|
|
#ifndef CUSTOM_TPBX_BITS
|
|
#define TPBX1 10 // top
|
|
#define TPBX2 9 // mid
|
|
#define TPBX3 9 // bottom
|
|
#endif /* CUSTOM_TPBX_BITS */
|
|
|
|
static inline constexpr uint32_t min3u32_xb(uint32_t a, uint32_t b, uint32_t c) noexcept {
|
|
return (a <= b) ?
|
|
((a <= c) ? a : c) :
|
|
((b <= c) ? b : c);
|
|
}
|
|
|
|
/**
|
|
* Simple three-pass (ok: 3 + 1) bottom-up internal radix sort writter for thiersort3
|
|
*
|
|
* @param a The array to sort - will be changed too!
|
|
* @param buf Result array with the same size - result will be here
|
|
* @param n The number of elements
|
|
*/
|
|
static inline void threepass_xb(uint32_t *a, uint32_t *buf, int n) noexcept {
|
|
assert(buf != NULL);
|
|
constexpr int shr1 = TPBX3 + TPBX2;
|
|
constexpr int shr2 = TPBX3;
|
|
constexpr int shr3 = 0;
|
|
constexpr int mask1 = (1 << TPBX1) - 1;
|
|
constexpr int mask2 = (1 << TPBX2) - 1;
|
|
constexpr int mask3 = (1 << TPBX3) - 1;
|
|
|
|
/* helper buffers. */
|
|
int sz = n * sizeof(a[0]);
|
|
|
|
static thread_local uint32_t bucket1[1 << TPBX1];
|
|
memset(bucket1, 0, (1 << TPBX1) * sizeof(uint32_t));
|
|
static thread_local uint32_t bucket2[1 << TPBX2];
|
|
memset(bucket2, 0, (1 << TPBX2) * sizeof(uint32_t));
|
|
static thread_local uint32_t bucket3[1 << TPBX3];
|
|
memset(bucket3, 0, (1 << TPBX3) * sizeof(uint32_t));
|
|
|
|
/* Count occurences (can count together with good ILP) */
|
|
#pragma GCC unroll 64
|
|
for(uint32_t i = 0; i < n; ++i) {
|
|
++bucket1[(a[i] >> shr1) & mask1];
|
|
++bucket2[(a[i] >> shr2) & mask2];
|
|
++bucket3[(a[i] >> shr3) & mask3];
|
|
}
|
|
|
|
/* Count prefix sums - try as much ILP as possible because bigger arrays than usual! */
|
|
uint32_t prev1 = 0;
|
|
uint32_t prev2 = 0;
|
|
uint32_t prev3 = 0;
|
|
uint32_t common = min3u32_xb(
|
|
(1 << TPBX1),
|
|
(1 << TPBX2),
|
|
(1 << TPBX3)
|
|
);
|
|
uint32_t i = 0;
|
|
#pragma GCC unroll 8
|
|
for (; i < common; ++i) {
|
|
bucket1[i] += prev1;
|
|
prev1 = bucket1[i];
|
|
bucket2[i] += prev2;
|
|
prev2 = bucket2[i];
|
|
bucket3[i] += prev3;
|
|
prev3 = bucket3[i];
|
|
}
|
|
/* Do remaining 1 */
|
|
for (uint32_t j = i; j < (1 << TPBX1); ++j) {
|
|
bucket1[j] += prev1;
|
|
prev1 = bucket1[j];
|
|
}
|
|
/* Do remaining 2 */
|
|
for (uint32_t j = i; j< (1 << TPBX2); ++j) {
|
|
bucket2[j] += prev2;
|
|
prev2 = bucket2[j];
|
|
}
|
|
/* Do remaining 3 */
|
|
for (uint32_t j = i; j < (1 << TPBX3); ++j) {
|
|
bucket3[j] += prev3;
|
|
prev3 = bucket3[j];
|
|
}
|
|
|
|
// Bottom digit a->buf
|
|
// right-to-left to ensure already sorted digits order we keep for iterations
|
|
#pragma GCC unroll 13
|
|
for(i = n; i >= 4; i -= 4) {
|
|
auto num0 = a[i - 1];
|
|
auto bkeyni0 = (num0 >> shr3) & mask3;
|
|
auto offset0 = --bucket3[bkeyni0];
|
|
buf[offset0] = num0;
|
|
auto num1 = a[i - 2];
|
|
auto bkeyni1 = (num1 >> shr3) & mask3;
|
|
auto offset1 = --bucket3[bkeyni1];
|
|
buf[offset1] = num1;
|
|
auto num2 = a[i - 3];
|
|
auto bkeyni2 = (num2 >> shr3) & mask3;
|
|
auto offset2 = --bucket3[bkeyni2];
|
|
buf[offset2] = num2;
|
|
auto num3 = a[i - 4];
|
|
auto bkeyni3 = (num3 >> shr3) & mask3;
|
|
auto offset3 = --bucket3[bkeyni3];
|
|
buf[offset3] = num3;
|
|
}
|
|
#pragma GCC unroll 4
|
|
for(; i > 0; --i) {
|
|
auto num = a[i - 1];
|
|
auto bkeyni = (num >> shr3) & mask3;
|
|
auto offset = --bucket3[bkeyni];
|
|
buf[offset] = num;
|
|
}
|
|
|
|
// Mid digit buf->a
|
|
// right-to-left to ensure already sorted digits order we keep for iterations
|
|
#pragma GCC unroll 13
|
|
for(i = n; i >= 4; i -= 4) {
|
|
auto num0 = buf[i - 1];
|
|
auto bkeyni0 = (num0 >> shr2) & mask2;
|
|
auto offset0 = --bucket2[bkeyni0];
|
|
a[offset0] = num0;
|
|
auto num1 = buf[i - 2];
|
|
auto bkeyni1 = (num1 >> shr2) & mask2;
|
|
auto offset1 = --bucket2[bkeyni1];
|
|
a[offset1] = num1;
|
|
auto num2 = buf[i - 3];
|
|
auto bkeyni2 = (num2 >> shr2) & mask2;
|
|
auto offset2 = --bucket2[bkeyni2];
|
|
a[offset2] = num2;
|
|
auto num3 = buf[i - 4];
|
|
auto bkeyni3 = (num3 >> shr2) & mask2;
|
|
auto offset3 = --bucket2[bkeyni3];
|
|
a[offset3] = num3;
|
|
}
|
|
#pragma GCC unroll 4
|
|
for(; i > 0; --i) {
|
|
auto num = buf[i - 1];
|
|
auto bkeyni = (num >> shr2) & mask2;
|
|
auto offset = --bucket2[bkeyni];
|
|
a[offset] = num;
|
|
}
|
|
// Top digit a->buf
|
|
// right-to-left to ensure already sorted digits order we keep for iterations
|
|
#pragma GCC unroll 13
|
|
for(i = n; i >= 4; i -= 4) {
|
|
auto num0 = a[i - 1];
|
|
auto bkeyni0 = (num0 >> shr1) & mask1;
|
|
auto offset0 = --bucket1[bkeyni0];
|
|
buf[offset0] = num0;
|
|
auto num1 = a[i - 2];
|
|
auto bkeyni1 = (num1 >> shr1) & mask1;
|
|
auto offset1 = --bucket1[bkeyni1];
|
|
buf[offset1] = num1;
|
|
auto num2 = a[i - 3];
|
|
auto bkeyni2 = (num2 >> shr1) & mask1;
|
|
auto offset2 = --bucket1[bkeyni2];
|
|
buf[offset2] = num2;
|
|
auto num3 = a[i - 4];
|
|
auto bkeyni3 = (num3 >> shr1) & mask1;
|
|
auto offset3 = --bucket1[bkeyni3];
|
|
buf[offset3] = num3;
|
|
}
|
|
#pragma GCC unroll 4
|
|
for(; i > 0; --i) {
|
|
auto num = a[i - 1];
|
|
auto bkeyni = (num >> shr1) & mask1;
|
|
auto offset = --bucket1[bkeyni];
|
|
buf[offset] = num;
|
|
}
|
|
}
|
|
|
|
#endif /* THREE_PASS_XB_H */
|