[Παράλληλα και Διανεμημένα Συστ.] Εργασία 1

[Thmmy.gr portal]

  Thmmy.gr portal
   Forum
   Downloads
   Ενεργ. Λογαριασμού
   Επικοινωνία
  
  Χρήσιμα links
   Σελίδα τμήματος
   Βιβλιοθήκη Τμήματος
   Elearning
   Φοιτητικά fora
   Πρόγραμμα Λέσχης
   Πρακτική Άσκηση
   Ηλεκτρονική Εξυπηρέτηση Φοιτητών
   Διανομή Συγγραμμάτων
   Ψηφιακό Καταθετήριο Διπλωματικών
   Πληροφορίες Καθηγητών
   Instagram @thmmy.gr
   mTHMMY
  
  Φοιτητικές Ομάδες
   ACM
   Aristurtle
   ART
   ASAT
   BEAM
   BEST Thessaloniki
   EESTEC LC Thessaloniki
   EΜΒ Auth
   IAESTE Thessaloniki
   IEEE φοιτητικό παράρτημα ΑΠΘ
   SpaceDot
   VROOM
   Panther
  

THMMY.gr Web

Helios_MultiScribbles2SMF Default ThemeSMFone_Blue

[Ανεβάζετε τα θέματα των εξετάσεων στον τομέα Downloads]

Είσαι πρωτοετής;... Καλώς ήρθες! Μπορείς να βρεις πληροφορίες εδώ. Βοήθεια για τους καινούργιους μέσω χάρτη.

Κατεβάστε εδώ το Android Application για εύκολη πρόσβαση στο forum.

Ανεβάζετε τα θέματα των εξετάσεων στον τομέα Downloads με προσοχή στα ονόματα των αρχείων!

[Admins]

Για αλλαγή του public name σας, επικοινωνήστε με έναν από τους Admins.

[georgkonst]

Εγώ προσπάθησα τις προηγούμενες με atomic/critical/( μια υλοποίηση με locks) αλλά οι χρόνοι πο πήρα ήταν πολύ κακοί!
Btw αν δε κάνεις μια από τις παραπάνω τεχνικές και βάλεις απλώς "pragma omp for", τότε δεν περνάει τα τεστ.
Οπότε φαντάζομαι δεν τις παραλληλοποιείς?

Όσο δοκίμασα και εγώ τις memcpy kai τις swap είτε γινόντουσαν οι χρόνοι μου χάλια ή δε περνούσα τα τεστ (μάλλον θα χρειαζόταν atomic/critical), νομίζω θα μείνω μόνο στη τελευταία, ούτως ή άλλως δε κερδίζεις πάρα πολλά από τη radix

[Andromedas]

Γενικά η διαφοροποίηση της recursive radix sort σε p-threads με openmp ή cilk είναι σίγουρα ότι λόγω της αναδρομής γίνεται καλά μόνο με p-threads. Τώρα υπάρχει παραλλαγή της radix sort και παραλληλοποίηση με την λογική scan prefix όπου θα δουλεύει καλύτερα σε openmp ή cilk . Δεν νομίζω ότι είναι υποχρεωτικό για την εργασία πάντως. (Αν ψηθεί, κανείς ας μου στείλει pm)

[BADBANE]

Μανκες στον διαδη τι τεστ πρεπει να τρεξουμε και με τι αριθμους;;

[ReMi0s]

στην υλοποίηση με pthread έχει καταφέρει κανείς να παραλληλοποιήσει την radix_sort για n threads;
έχω δοκιμάσει 30 διαφορετικά πράγματα και είτε  παίρνω κάποιο error είτε fail στα test
αυτό που με προβληματίζει περισσότερο είναι η τελευταία δοκιμή όπου αφού τρέξει η radix μία φορά σειριακά έπειτα δημιουργώ 8 thread και καλώ την παράλληλη. Αφού τρέξει η παράλληλη όπως η κανονική έκδοση εξετάζω αν (activethreads<NumThreads) και αν γίνεται δημιουργώ καινούριο thread αλλιώς συνεχίζει σειριακά

τις μισές φορές μου βγάζει σωστά αποτελέσματα, τις μισές λάθος και κάποιες ελάχιστες φορές segmentation fault αλλα όχι πάντα.

κανένα καλό παλικάρι να προσφέρει καμιά  ιδέα περι αυτού ή κάποια άλλη κατεύθυνση;

Ευχαριστώ

[Ser Harry Man]

Κάνεις mute τον αριθμό των threads που τρέχουν, όταν πας να τον μεταβάλλεις?

Mutex εννοείται, ναι.

[Ser Harry Man]

μία λύση αλλα όχι βέλτιστη είναι να τρέχει μία φορά η radix σειριακά και στο σημείο που κάνει recursive για maxbin να καλείς την παράλληλη , που έχει πάλι τον ίδιο κώδικα... Έτσι όμως δημιουργούνται μόνο 8 threads σταθερά. Όταν ρώτησα τον πιτσιάνη μου είπε οτι θέλει να μπορούμε εμείς να αλλάξουμε τα thread

Ποιά είναι η βέλτιστη λοιπόν ? Και εφ'όσον είναι recursive γιατί θα βγούν μόνο 8 ?

[Ser Harry Man]

στην radix sort που λέει :
    // scan prefix (must change this code) 
είναι απαραίτητο να κάνουμε αλλαγή του κώδικα στην περιοχή αυτή ;  έχω  δοκιμάσει πολλούς τρόπους για να βελτιστοποιήσω τον χρόνο της συνάρτησης αυτής με χρήση OpenMP αλλά πάντα κάτι δεν πάει καλά ... σκέφτομαι μήπως ο λόγος είναι ότι δν έχω ψάξει να αλλάξω αυτό το το κομμάτι του κώδικα.

Κάποια ιδέα ή παρατήρηση ;

Αν δείς επάνω έχει 2 συναρτήσεις swap που δεν έχει χρησιμοποιήσει, ενώ στο scan prefix κάνει στην ουσία swap. Ipso facto , ήταν note για τον εαυτό του. Όπως είπαν κ οι άλλοι, δεν μπορείς να παραλληλοποιήσεις κάτι εκεί.

[Ser Harry Man]

στην υλοποίηση με pthread έχει καταφέρει κανείς να παραλληλοποιήσει την radix_sort για n threads;
έχω δοκιμάσει 30 διαφορετικά πράγματα και είτε  παίρνω κάποιο error είτε fail στα test
αυτό που με προβληματίζει περισσότερο είναι η τελευταία δοκιμή όπου αφού τρέξει η radix μία φορά σειριακά έπειτα δημιουργώ 8 thread και καλώ την παράλληλη. Αφού τρέξει η παράλληλη όπως η κανονική έκδοση εξετάζω αν (activethreads<NumThreads) και αν γίνεται δημιουργώ καινούριο thread αλλιώς συνεχίζει σειριακά

τις μισές φορές μου βγάζει σωστά αποτελέσματα, τις μισές λάθος και κάποιες ελάχιστες φορές segmentation fault αλλα όχι πάντα.

κανένα καλό παλικάρι να προσφέρει καμιά  ιδέα περι αυτού ή κάποια άλλη κατεύθυνση;

Ευχαριστώ

Και εγώ πιστεύω οτι κάνω πάνω κάτω το ίδιο με εσένα. Για να μην πολυλογώ, έλεγξε οτι όλα τα threads κάνουν join σωστά και δεν τερματίζει το αρχικό πρίν κάνουν όλα τη δουλειά τους.

[fibonacci]

Και εγώ πιστεύω οτι κάνω πάνω κάτω το ίδιο με εσένα. Για να μην πολυλογώ, έλεγξε οτι όλα τα threads κάνουν join σωστά και δεν τερματίζει το αρχικό πρίν κάνουν όλα τη δουλειά τους.

Στην παραλληλοποίηση με Pthreads της αναδρομικής κλήσης ορίζετε ως init_function των threads την ίδια την συνάρτηση truncated_radix_sort() ή φτιάχνεται με καινουρια η οποία καλεί για κάθε καινουριο thread την truncated_radix_sort() ;  εγώ επιλέγω το δεύτερο για να μπορώ να περάσω τα ορίσματα με ένα struct .

Επίσης την pthreads_join() την τρέχεται για κάθε ανδρομική κλήση μετά την επαναληπτική δημιουργία των threads ;
 Γιατί σε μένα φτάνει στην radix_sort η εκτέλεση του προγράμματος αυξάνεται ραγδαία ο αριθμός των νημάτων του συστήματος , η χρήση cpu φτάνει στο 100% για λίγο και μετά με πετάει από την εκτέλεση του προγράμματος χωρίς κανένα αποτέλεσμα

Ελπίζω να ήμουν κατατοπιστικός

[ReMi0s]

Ποιά είναι η βέλτιστη λοιπόν ? Και εφ'όσον είναι recursive γιατί θα βγούν μόνο 8 ?

η βέλτιστη θα ήταν φαντάζομαι να δημιουργούνται όσα thread ζητάς απο το πληκτρολόγιο. Το λέω γιατί ο πιτσίανης όταν είπα οτι την έκανα με σταθερά thread δεν του άρεσε.
Επίσης βγαίνουμ μόνο 8 γιατί τα δημιουργείς μέσα στην main και έπειτα καλείς συνέχεια την παραληλοποιημένη της.Μόνο μια φορά θα τρέχει η main
Βέβαια αυτό είναι μία ιδέα, υπάρχουν πολλές...

Και εγώ πιστεύω οτι κάνω πάνω κάτω το ίδιο με εσένα. Για να μην πολυλογώ, έλεγξε οτι όλα τα threads κάνουν join σωστά και δεν τερματίζει το αρχικό πρίν κάνουν όλα τη δουλειά τους.

το ελέγχω αυτό, γιατί στην αρχή είχα θέμα και μου έβγαζε error η join. Βέβαια όταν κανει fail κάνει για πολύ μιικρή διαφορά δλδ λείπουν λίγα σωματίδια απο τα N που είχα επιλέξει. Ίσως είναι εκεί το θέμα όντως.

Στην παραλληλοποίηση με Pthreads της αναδρομικής κλήσης ορίζετε ως init_function των threads την ίδια την συνάρτηση truncated_radix_sort() ή φτιάχνεται με καινουρια η οποία καλεί για κάθε καινουριο thread την truncated_radix_sort() ;  εγώ επιλέγω το δεύτερο για να μπορώ να περάσω τα ορίσματα με ένα struct .

Επίσης την pthreads_join() την τρέχεται για κάθε ανδρομική κλήση μετά την επαναληπτική δημιουργία των threads ;
 Γιατί σε μένα φτάνει στην radix_sort η εκτέλεση του προγράμματος αυξάνεται ραγδαία ο αριθμός των νημάτων του συστήματος , η χρήση cpu φτάνει στο 100% για λίγο και μετά με πετάει από την εκτέλεση του προγράμματος χωρίς κανένα αποτέλεσμα

Ελπίζω να ήμουν κατατοπιστικός

εγώ κάνω μια παράλληλη συνάρτηση και καλώ συνέχεια αυτή, είτε με pthread_create, είτε με το όνομα της.

Το join το κάνω στην truncated..

[nikoscha]

Γιατί όταν ανεβάζω thread πάνω απο 8 οι χρόνοι αρχίζουν να χειροτερεύουν;

[Kthulu]

Γιατι λογικα ο επεξεργαστης σου εχει 8 threads.

[fibonacci]

Με την omp_set_num_threads() ορίζω το  αριθμό threads προς χρηση για την επόμενη παράλληλη περιοχή ή γενικά για την εκτέλεση ολου του προγράμματος; ... Δηλαδή αν την καλέσω πριν την παραλληλοποιημένη for στην οποία κάνω αναδρομική κλήση  θα μου ορίσει το αριθμό των thread που θα τρέξουν την αναδρομή ή θα μου επιβάλει έναν συνολικό αριθμό threads που μπορώ να χρησιμοποιήσω για οποιαδήποτα for σε κάποια κλήση αναδρομής ;

[ReMi0s]

παιδιά την βοήθεια σας λίγο.
θέλω να έχω μία global μεταβλητή int active_threads
και οταν την αλλάζω μέσα σε συναρτήσεις να αλλάζει γενικά η τιμή της και όχι μόνο στην συνάρτηση αυτή.
αμα την ορίσω απλά έτσι δεν γίνεται.
πρέπει να το κάνω με pointer αλλα δεν θυμάμαι Tongue
κάποιος βοήθεια;

[Vlassis]

παιδιά την βοήθεια σας λίγο.
θέλω να έχω μία global μεταβλητή int active_threads
και οταν την αλλάζω μέσα σε συναρτήσεις να αλλάζει γενικά η τιμή της και όχι μόνο στην συνάρτηση αυτή.
αμα την ορίσω απλά έτσι δεν γίνεται.
πρέπει να το κάνω με pointer αλλα δεν θυμάμαι Tongue
κάποιος βοήθεια;

δεν ξερω αν καταλαβα ακριβως τι θες, εγω ορισα μια μεταβλητη threads global εξω απο τη main στο αρχειο test_octree.c, στην οποια εχω δωσει default τιμη αλλα και της δινω την δυνατοτητα να αλλαξει τιμη μεσα στη συναρτηση
και απ οτι βλεπω, πιανει σε ολες τις συναρτησεις η αλλαγη της τιμης